Method: Rmega::Pool#initialize

Defined in:
lib/rmega/pool.rb

#initialize ⇒ Pool

Returns a new instance of Pool.



5
6
7
8
9
10
11
12
13
14
 
# File 'lib/rmega/pool.rb', line 5

def initialize
  threads_raises_exceptions

  @mutex = Mutex.new
  @resource = ConditionVariable.new
  @max = options.thread_pool_size

  @running = []
  @queue = []
end