Class: GitMulticast::Task::Pool

Inherits:

Object

• Object
• GitMulticast::Task::Pool

Defined in:

lib/git_multicast/task/pool.rb

Class Method Summary

• .pool ⇒ Object

Instance Method Summary

• #initialize(size) ⇒ Pool constructor

  A new instance of Pool.

• #schedule(*args, &blk) ⇒ Object
• #shutdown ⇒ Object

Constructor Details

#initialize(size) ⇒ Pool

Returns a new instance of Pool.

# File 'lib/git_multicast/task/pool.rb', line 10

def initialize(size)
  @size = size
  @queue = Queue.new
  @pool = (1..size).map { Thread.new(&job_loop) }
end

Class Method Details

.pool ⇒ Object

# File 'lib/git_multicast/task/pool.rb', line 6

def self.pool
  @pool ||= new(20)
end

Instance Method Details

#schedule(*args, &blk) ⇒ Object

# File 'lib/git_multicast/task/pool.rb', line 16

def schedule(*args, &blk)
  queue << [blk, args]
end

#shutdown ⇒ Object

# File 'lib/git_multicast/task/pool.rb', line 20

def shutdown
  size.times { schedule { throw :exit } }
  pool.map(&:join)
end