fix deque ?

This commit is contained in:
Xuan Son Nguyen 2024-09-06 10:22:08 +02:00
parent 040fddee1c
commit 2ab3da68e2

View file

@ -470,8 +470,8 @@ struct server_queue {
std::unique_lock<std::mutex> lock(mutex_tasks); std::unique_lock<std::mutex> lock(mutex_tasks);
if (!queue_tasks_deferred.empty()) { if (!queue_tasks_deferred.empty()) {
server_task task = queue_tasks_deferred.front(); server_task task = queue_tasks_deferred.front();
queue_tasks_deferred.erase(queue_tasks_deferred.begin()); queue_tasks_deferred.pop_front();
queue_tasks.push_back(task); queue_tasks.push_back(std::move(task));
} }
} }
@ -502,7 +502,7 @@ struct server_queue {
break; break;
} }
server_task task = queue_tasks.front(); server_task task = queue_tasks.front();
queue_tasks.erase(queue_tasks.begin()); queue_tasks.pop_front();
lock.unlock(); lock.unlock();
LOG_VERBOSE("callback_new_task", {{"id_task", task.id}}); LOG_VERBOSE("callback_new_task", {{"id_task", task.id}});
callback_new_task(task); callback_new_task(task);