class Concurrent::RubyThreadPoolExecutor::Worker

def initialize(pool)

def initialize(pool)
  # instance variables accessed only under pool's lock so no need to sync here again
  @queue  = Queue.new
  @pool   = pool
  @thread = create_worker @queue, pool, pool.idletime
end