diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-21 10:47:33 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-21 10:47:33 +0200 |
| commit | 961243065ac51eb7333291149e0164adc6c772c4 (patch) | |
| tree | 47108493eba7ec341c8c744ecd4568f5cf36af8f /lib | |
| parent | add role for job (diff) | |
| download | presque-worker-961243065ac51eb7333291149e0164adc6c772c4.tar.gz | |
idle if no job; else fetch next job
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/presque/worker.pm | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/presque/worker.pm b/lib/presque/worker.pm index c7fa36f..80f9493 100644 --- a/lib/presque/worker.pm +++ b/lib/presque/worker.pm @@ -48,11 +48,15 @@ sub start { while (!$self->shut_down) { my $job = $self->rest_fetch_job(); - $self->work($job) if $job; - sleep($self->interval); + $job ? $self->work($job) : $self->idle(); + } } +sub idle { + sleep($self->interval); +} + 1; __END__ |