Class: Kudzu::ThreadPool

Inherits:

Object

• Object
• Kudzu::ThreadPool

Defined in:

lib/kudzu/thread_pool.rb

Instance Method Summary

• #initialize(size) ⇒ ThreadPool constructor

  A new instance of ThreadPool.

• #shutdown ⇒ Object
• #start(&block) ⇒ Object
• #wait ⇒ Object

Constructor Details

#initialize(size) ⇒ ThreadPool

Returns a new instance of ThreadPool.

# File 'lib/kudzu/thread_pool.rb', line 5

def initialize(size)
  @size = size
  @queue = Queue.new
  @threads = []
end

Instance Method Details

#shutdown ⇒ Object

# File 'lib/kudzu/thread_pool.rb', line 22

def shutdown
  @threads.each { |t| t.kill }
  @threads = []
end

#start(&block) ⇒ Object

# File 'lib/kudzu/thread_pool.rb', line 11

def start(&block)
  @threads = 1.upto(@size).map { create_thread(&block) }
end

#wait ⇒ Object

# File 'lib/kudzu/thread_pool.rb', line 15

def wait
  until @queue.num_waiting == @threads.select { |t| t.alive? }.size
    Thread.pass
    sleep 1
  end
end