Method ClearDelayTask

src/sdk/table_impl.cc:2253–2267

}

void TableImpl::ClearDelayTask() {
  MutexLock lock(&delay_task_id_mutex_);
  std::set<int64_t>::iterator it = delay_task_ids_.begin();
  while (it != delay_task_ids_.end()) {
    int64_t task_id = *it;
    // may deadlock, MUST unlock
    delay_task_id_mutex_.Unlock();
    bool cancelled = thread_pool_->CancelTask(*it);
    delay_task_id_mutex_.Lock();
    if (cancelled) {
      delay_task_ids_.erase(task_id);
    }
    it = delay_task_ids_.begin();
  }
}

void TableImpl::BreakRequest(int64_t task_id) {
  SdkTask* task = task_pool_.PopTask(task_id);