| 194 | |
| 195 | template <typename TaskType> |
| 196 | void Batch<TaskType>::AddTask(std::unique_ptr<TaskType> task) { |
| 197 | DCHECK(!IsClosed()); |
| 198 | { |
| 199 | mutex_lock l(mu_); |
| 200 | size_ += task->size(); |
| 201 | tasks_.push_back(std::move(task)); |
| 202 | } |
| 203 | } |
| 204 | |
| 205 | template <typename TaskType> |
| 206 | std::unique_ptr<TaskType> Batch<TaskType>::RemoveTask() { |