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

Check whether a job is cancelled in ThreadPool's update(). Also Improved the logic of the worker thread func a bit.

Browse Source
This commit is contained in:
Relintai 2022-02-14 12:44:09 +01:00
parent c401b7a027
commit 1e2a611ebd
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
thread_pool.cpp
View File

@ -233,8 +233,15 @@ void ThreadPool::_worker_thread_func(void *user_data) {
while (context->running) {
context->semaphore->wait();
if (!context->job.is_valid())
if (!context->job.is_valid()) {
ThreadPool::get_singleton()->_thread_finished(context);
continue;
}
if (context->job->get_cancelled()) {
ThreadPool::get_singleton()->_thread_finished(context);
continue;
}
context->job->execute();
@ -265,7 +272,7 @@ void ThreadPool::update() {
remaining_time -= job->get_current_execution_time();
if (job->get_complete()) {
if (job->get_complete() || job->get_cancelled()) {
_queue.write[_current_queue_head++].unref();
}
}