RQ::SleepCycle (Class)

In: lib/rq-2.3.1/sleepcycle.rb
Parent: Array
MainHelper StatusLister Snapshotter ReSubmitter Feeder Deleter Relayer Executor Submitter Locker Backer Configurator Lister Rotater Creator Updater Querier ::Hash ConfigFile DRbUndumped JobRunner Main QDB JobQueue JobRunnerDaemon Array SleepCycle Job ArrayFields ::OrderedHash OrderedAutoHash LogMethods Refresher lib/rq-2.3.1/rotater.rb lib/rq-2.3.1/sleepcycle.rb lib/rq-2.3.1/statuslister.rb lib/rq-2.3.1/updater.rb lib/rq-2.3.1/relayer.rb lib/rq-2.3.1/creator.rb lib/rq-2.3.1/lister.rb lib/rq-2.3.1/snapshotter.rb bin/rq.rb lib/rq-2.3.1/resubmitter.rb lib/rq-2.3.1/orderedautohash.rb lib/rq-2.3.1/locker.rb lib/rq-2.3.1/querier.rb lib/rq-2.3.1/submitter.rb lib/rq-2.3.1/configfile.rb lib/rq-2.3.1/executor.rb lib/rq-2.3.1/refresher.rb lib/rq-2.3.1/job.rb lib/rq-2.3.1/mainhelper.rb lib/rq-2.3.1/qdb.rb lib/rq-2.3.1/feeder.rb lib/rq-2.3.1/configurator.rb lib/rq-2.3.1/deleter.rb lib/rq-2.3.1/jobqueue.rb lib/rq-2.3.1/jobrunnerdaemon.rb lib/rq-2.3.1/backer.rb lib/rq-2.3.1/jobrunner.rb Usage Util LogClassMethods LoggerExt LogMethods Logging RQ Module: RQ

the sleepcycle class provides timeouts for better than average polling performance by the locking protocol used by the QDB

Methods

new   next   reset  

Attributes

inc  [R] 
max  [R] 
min  [R] 
range  [R] 

Public Class methods

newmin, max, inc

[Source]

    # File lib/rq-2.3.1/sleepcycle.rb, line 17
17:       def initialize min, max, inc
18: #--{{{
19:         @min, @max, @inc = Float(min), Float(max), Float(inc)
20:         @range = @max - @min
21:         raise RangeError, "max < min" if @max < @min
22:         raise RangeError, "inc > range" if @inc > @range
23:         s = @min
24:         push(s) and s += @inc while(s <= @max)
25:         self[-1] = @max if self[-1] < @max
26:         reset
27: #--}}}
28:       end

Public Instance methods

next()

[Source]

    # File lib/rq-2.3.1/sleepcycle.rb, line 29
29:       def next
30: #--{{{
31:         ret = self[@idx]
32:         @idx = ((@idx + 1) % self.size)
33:         ret
34: #--}}}
35:       end
reset()

[Source]

    # File lib/rq-2.3.1/sleepcycle.rb, line 36
36:       def reset
37: #--{{{
38:         @idx = 0
39: #--}}}
40:       end

[Validate]