class Concurrent::SafeTaskExecutor

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