module Workers
Constants
- VERSION
Public Class Methods
lock() { || ... }
click to toggle source
# File lib/workers.rb, line 52 def self.lock(&block) (@lock ||= Monitor.new).synchronize { yield if block_given? } end
map(inputs, options = {}) { |i| ... }
click to toggle source
# File lib/workers.rb, line 46 def self.map(inputs, options = {}, &block) return Workers::TaskGroup.new.map(inputs, options) do |i| yield(i) end end
pool()
click to toggle source
# File lib/workers.rb, line 20 def self.pool lock do @pool ||= Workers::Pool.new end end
pool=(val)
click to toggle source
# File lib/workers.rb, line 26 def self.pool=(val) lock do @pool.dispose if @pool @pool = val end end
scheduler()
click to toggle source
# File lib/workers.rb, line 33 def self.scheduler lock do @scheduler ||= Workers::Scheduler.new end end
scheduler=(val)
click to toggle source
# File lib/workers.rb, line 39 def self.scheduler=(val) lock do @scheduler.dispose if @scheduler @scheduler = val end end