class Concurrent::RubyThreadPoolExecutor::Worker

def <<(message)

def <<(message)
  @queue << message
end