Method: Plum::Rack::ThreadPool#initialize

Defined in:
lib/plum/rack/thread_pool.rb

#initialize(size = 20) ⇒ ThreadPool

Returns a new instance of ThreadPool.



5
6
7
8
9
10
11
12
# File 'lib/plum/rack/thread_pool.rb', line 5

def initialize(size = 20)
  @workers = Set.new
  @jobs = Queue.new

  size.times { |i|
    spawn_worker
  }
end