Method CancelTask

src/common/thread_pool.h:108–138

Cancel a delayed task if running, wait if non_block==false; return immediately if non_block==true

  /// if running, wait if non_block==false; return immediately if
  /// non_block==true
  bool CancelTask(int64_t task_id, bool non_block = false, bool* is_running = NULL) {
    if (task_id == 0) {
      if (is_running != NULL) {
        *is_running = false;
      }
      return false;
    }
    while (1) {
      {
        MutexLock lock(&mutex_);
        if (running_task_ids_.find(task_id) == running_task_ids_.end()) {
          BGMap::iterator it = latest_.find(task_id);
          if (it == latest_.end()) {
            if (is_running != NULL) {
              *is_running = false;
            }
            return false;
          }
          latest_.erase(it);
          return true;
        } else if (non_block) {
          if (is_running != NULL) {
            *is_running = true;
          }
          return false;
        }
      }
      timespec ts = {0, 100000};
      nanosleep(&ts, &ts);
    }
  }
  int64_t PendingNum() const { return pending_num_; }

  // log format: 3 numbers seperated by " ", e.g. "15 24 32"