class Bundler::Worker
def initialize(size, name, func)
-
func
(Proc
) -- job to run in inside the worker pool -
name
(String
) -- name the name of the worker -
size
(Integer
) -- Size of pool
def initialize(size, name, func) @name = name @request_queue = Thread::Queue.new @response_queue = Thread::Queue.new @func = func @size = size @threads = nil @previous_interrupt_handler = nil end