class Concurrent::RubyThreadPoolExecutor

def create_worker_thread
  wrkr = RubyThreadPoolWorker.new(@queue, self)
  Thread.new(wrkr, self) do |worker, parent|
    Thread.current.abort_on_exception = false
    worker.run
    parent.on_worker_exit(worker)
  end
  return wrkr
end