Method WorkerExecute

be/src/util/thread-pool.h:263–267

This is called by the worker thread and handles the mechanics of notifying the caller and conveying status when Execute() completes.

  /// This is called by the worker thread and handles the mechanics of notifying
  /// the caller and conveying status when Execute() completes.
  void WorkerExecute() {
    Status status = Execute();
    DCHECK(!done_promise_.IsSet());
    discard_result(done_promise_.Set(status));
  }

  /// Wait for the operation to complete or time out with the specified limit
  /// 'timeout_millis' given that the caller has already waited 'time_used_millis'.