denshooter/mxtasking
1
0
Fork 0
mirror of https://github.com/mmueller41/mxtasking.git synced 2026-01-21 12:42:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

Yield thread if task queues are empty

Browse Source
This commit is contained in:
Michael Mueller
2024-10-22 15:00:54 +02:00
parent f701cb1f8d
commit eaa636edcb
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/mx/tasking/worker.cpp
View File

@@ -40,7 +40,7 @@ void Worker::execute()
while (this->_is_running == false) while (this->_is_running == false)
{ {
rt::Mutex mutex{}; rt::Mutex mutex{};
_stop.WaitTimed(&mutex, 10); _stop.Wait(&mutex);
_counter.fetch_add(1); _counter.fetch_add(1);
//std::cout << "Worker " << _target_core_id << " woke up " << std::endl; //std::cout << "Worker " << _target_core_id << " woke up " << std::endl;
} }
@@ -51,6 +51,9 @@ void Worker::execute()
} }
this->_channel_size = this->_channel.fill(); this->_channel_size = this->_channel.fill();
if (this->_channel.empty()) {
thread_yield();
}
if constexpr (config::task_statistics()) if constexpr (config::task_statistics())
{ {