class Concurrent::SafeTaskExecutor

def execute(*args)
  synchronize do
    success = false
    value   = reason = nil
    begin
      value   = @task.call(*args)
      success = true
    rescue @exception_class => ex
      reason  = ex
      success = false
    end
    [success, value, reason]
  end
end