module Workers

# File lib/workers.rb, line 52
def self.lock(&block)
  (@lock ||= Monitor.new).synchronize { yield if block_given? }
end

# 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

# File lib/workers.rb, line 20
def self.pool
  lock do
    @pool ||= Workers::Pool.new
  end
end

# File lib/workers.rb, line 26
def self.pool=(val)
  lock do
    @pool.dispose if @pool
    @pool = val
  end
end

# File lib/workers.rb, line 33
def self.scheduler
  lock do
    @scheduler ||= Workers::Scheduler.new
  end
end

# File lib/workers.rb, line 39
def self.scheduler=(val)
  lock do
    @scheduler.dispose if @scheduler
    @scheduler = val
  end
end