niansa/cosched
1
0
Fork 0
mirror of https://gitlab.com/niansa/cosched.git synced 2025-03-06 20:53:26 +01:00
Code Releases Activity

Resource deadlock avoided

Browse source
This commit is contained in:
niansa 2023-05-05 21:00:00 +02:00
parent a95878f505
commit 32bfe1dbac
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
scheduled_thread.cpp
View file

@ -13,9 +13,9 @@ void ScheduledThread::main_loop() {
std::unique_lock L(queue_mutex); std::unique_lock L(queue_mutex);
while (!queue.empty()) { while (!queue.empty()) {
// Get queue entry // Get queue entry
L.lock();
auto e = std::move(queue.front()); auto e = std::move(queue.front());
queue.pop(); queue.pop();
// Unlock queue
L.unlock(); L.unlock();
// Create task for it // Create task for it
sched.create_task(e.task_name); sched.create_task(e.task_name);
@ -23,6 +23,8 @@ void ScheduledThread::main_loop() {
auto& start_fcn = std::any_cast<decltype(e.start_fcn)&>(Task::get_current().properties.emplace("start_function", std::move(e.start_fcn)).first->second); auto& start_fcn = std::any_cast<decltype(e.start_fcn)&>(Task::get_current().properties.emplace("start_function", std::move(e.start_fcn)).first->second);
// Call start function // Call start function
start_fcn(); start_fcn();
// Lock queue
L.lock();
} }
} }
// Run once // Run once