Method: Temporal::ThreadPool#initialize

Defined in:
lib/temporal/thread_pool.rb

#initialize(size) ⇒ ThreadPool

Returns a new instance of ThreadPool.



12
13
14
15
16
17
18
19
20
21
 
# File 'lib/temporal/thread_pool.rb', line 12

def initialize(size)
  @size = size
  @queue = Queue.new
  @mutex = Mutex.new
  @availability = ConditionVariable.new
  @available_threads = size
  @pool = Array.new(size) do |i|
    Thread.new { poll }
  end
end