Module: Workers

Defined in:
lib/workers.rb,
lib/workers/pool.rb,
lib/workers/task.rb,
lib/workers/event.rb,
lib/workers/timer.rb,
lib/workers/worker.rb,
lib/workers/helpers.rb,
lib/workers/version.rb,
lib/workers/log_proxy.rb,
lib/workers/scheduler.rb,
lib/workers/task_group.rb,
lib/workers/periodic_timer.rb

Defined Under Namespace

Modules: Helpers Classes: Event, LogProxy, PeriodicTimer, Pool, Scheduler, Task, TaskGroup, Timer, Worker

Constant Summary collapse

VERSION = 
'0.1.3'

Class Method Summary collapse

Class Method Details

.map(vals, &block) ⇒ Object 



35
36
37
38
39
 
# File 'lib/workers.rb', line 35

def self.map(vals, &block)
  return Workers::TaskGroup.new.map(vals) do |v|
    block.call(v)
  end
end

.pool ⇒ Object 



17
18
19
 
# File 'lib/workers.rb', line 17

def self.pool
  return @pool ||= Workers::Pool.new
end

.pool=(val) ⇒ Object 



21
22
23
24
 
# File 'lib/workers.rb', line 21

def self.pool=(val)
  @pool.dispose if @pool
  @pool = val
end

.scheduler ⇒ Object 



26
27
28
 
# File 'lib/workers.rb', line 26

def self.scheduler
  return @scheduler ||= Workers::Scheduler.new
end

.scheduler=(val) ⇒ Object 



30
31
32
33
 
# File 'lib/workers.rb', line 30

def self.scheduler=(val)
  @scheduler.dispose if @scheduler
  @scheduler = val
end