Class: Atig::Scheduler
Instance Attribute Summary collapse
-
#search ⇒ Object
readonly
Returns the value of attribute search.
Instance Method Summary collapse
- #delay(interval, opts = {}, &f) ⇒ Object
-
#initialize(context, api, search, stream) ⇒ Scheduler
constructor
A new instance of Scheduler.
- #limit ⇒ Object
- #re_try(count, &f) ⇒ Object
- #remain ⇒ Object
- #repeat(interval, opts = {}, &f) ⇒ Object
- #reset ⇒ Object
- #stream(&f) ⇒ Object
Methods included from ExceptionUtil
Constructor Details
#initialize(context, api, search, stream) ⇒ Scheduler
Returns a new instance of Scheduler.
11 12 13 14 15 16 17 18 19 20 21 22 23 |
# File 'lib/atig/scheduler.rb', line 11 def initialize(context, api, search, stream) @log = context.log @api = api @search = search @stream = stream @agents = [] @queue = SizedQueue.new 10 daemon do f = @queue.pop f.call end end |
Instance Attribute Details
#search ⇒ Object (readonly)
Returns the value of attribute search.
9 10 11 |
# File 'lib/atig/scheduler.rb', line 9 def search @search end |
Instance Method Details
#delay(interval, opts = {}, &f) ⇒ Object
38 39 40 41 |
# File 'lib/atig/scheduler.rb', line 38 def delay(interval, opts={}, &f) sleep interval @queue.push(lambda{ safe { f.call @api } }) end |
#limit ⇒ Object
67 68 69 |
# File 'lib/atig/scheduler.rb', line 67 def limit @api.limit end |
#re_try(count, &f) ⇒ Object
51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
# File 'lib/atig/scheduler.rb', line 51 def re_try(count, &f) begin f.call rescue => e log :error, [count, e.inspect].inspect if count > 0 count -= 1 sleep 1 log :debug, "retry" retry end log :error, "Some Error Happened: #{e}" raise e end end |
#remain ⇒ Object
71 72 73 |
# File 'lib/atig/scheduler.rb', line 71 def remain @api.remain end |
#repeat(interval, opts = {}, &f) ⇒ Object
25 26 27 28 29 30 31 32 33 34 35 36 |
# File 'lib/atig/scheduler.rb', line 25 def repeat(interval,opts={}, &f) @queue.push(lambda{ safe { f.call @api } }) t = daemon do sleep interval log :debug, "agent #{t.inspect} is invoked" @queue.push(lambda{ safe { f.call @api } }) end log :info, "repeat agent #{t.inspect} is registered" @agents << t t end |
#reset ⇒ Object
75 76 77 |
# File 'lib/atig/scheduler.rb', line 75 def reset @api.reset end |
#stream(&f) ⇒ Object
43 44 45 46 47 48 49 |
# File 'lib/atig/scheduler.rb', line 43 def stream(&f) return nil unless @stream @stream_thread.kill if @stream_thread @stream_thread = daemon { f.call @stream } end |