Class: Plum::Rack::ThreadPool

Inherits:

Object

• Object
• Plum::Rack::ThreadPool

Defined in:

lib/plum/rack/thread_pool.rb

Instance Method Summary

• #acquire(tag = nil, err = nil, &blk) ⇒ Object

  returns cancel token.

• #initialize(size) ⇒ ThreadPool constructor

  A new instance of ThreadPool.

Constructor Details

#initialize(size) ⇒ ThreadPool

Returns a new instance of ThreadPool.

# File 'lib/plum/rack/thread_pool.rb', line 5

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

  size.times { |i|
    spawn_worker
  }
end

Instance Method Details

#acquire(tag = nil, err = nil, &blk) ⇒ Object

returns cancel token

# File 'lib/plum/rack/thread_pool.rb', line 15

def acquire(tag = nil, err = nil, &blk)
  @jobs << [blk, err]
end