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