| 2243 | } |
| 2244 | |
| 2245 | int64_t TableImpl::AddDelayTask(int64_t delay_time, ThreadPool::Task task) { |
| 2246 | MutexLock lock(&delay_task_id_mutex_); |
| 2247 | ThreadPool::Task t = std::bind(&TableImpl::DelayTaskWrapper, this, task, _1); |
| 2248 | int64_t t_id = thread_pool_->DelayTask(delay_time, t); |
| 2249 | delay_task_ids_.insert(t_id); |
| 2250 | return t_id; |
| 2251 | } |
| 2252 | |
| 2253 | void TableImpl::ClearDelayTask() { |
| 2254 | MutexLock lock(&delay_task_id_mutex_); |