Relintai/thread_pool
1
0
Fork 0
mirror of https://github.com/Relintai/thread_pool.git synced 2024-11-14 10:27:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Improve the logic int _thread_finished a bit. It saves a few _thread_finished calls in certain situations.

Browse Source
This commit is contained in:
Relintai 2022-02-19 16:30:34 +01:00
parent 1e2a611ebd
commit 0917511d04
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
thread_pool.cpp
View File

@ -216,12 +216,19 @@ void ThreadPool::_thread_finished(ThreadPoolContext *context) {
context->job.unref(); context->job.unref();
if (_current_queue_head != _current_queue_tail) { while (_current_queue_head != _current_queue_tail) {
context->job = _queue.get(_current_queue_head); context->job = _queue.get(_current_queue_head);
if (!context->job.is_valid()) {
++_current_queue_head;
continue;
}
context->semaphore->post(); context->semaphore->post();
_queue.write[_current_queue_head].unref(); _queue.write[_current_queue_head].unref();
++_current_queue_head; ++_current_queue_head;
break;
} }
_THREAD_SAFE_UNLOCK_ _THREAD_SAFE_UNLOCK_