class Concurrent::PerThreadExecutor

def <<(task)

def <<(task)
  PerThreadExecutor.post(&task)
  return self
end