| 226 | // |
| 227 | |
| 228 | void server_response::add_waiting_task_id(int id_task) { |
| 229 | RES_DBG("add task %d to waiting list. current waiting = %d (before add)\n", id_task, (int) waiting_task_ids.size()); |
| 230 | |
| 231 | std::unique_lock<std::mutex> lock(mutex_results); |
| 232 | waiting_task_ids.insert(id_task); |
| 233 | } |
| 234 | |
| 235 | void server_response::add_waiting_task_ids(const std::unordered_set<int> & id_tasks) { |
| 236 | std::unique_lock<std::mutex> lock(mutex_results); |