class Airbrake::ThreadPool
def initialize(worker_size:, queue_size:, block:, name: nil)
def initialize(worker_size:, queue_size:, block:, name: nil) @name = name @worker_size = worker_size @queue_size = queue_size @block = block @queue = SizedQueue.new(queue_size) @workers = ThreadGroup.new @mutex = Mutex.new @pid = nil @closed = false has_workers? end