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

Also invert the logic.

Browse Source
This commit is contained in:
Relintai 2020-05-24 20:07:30 +02:00
parent 967b21da87
commit d182f9a24f
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
thread_pool_job.cpp
View File

@ -94,12 +94,12 @@ float ThreadPoolJob::get_current_execution_time() {
bool ThreadPoolJob::should_do(const bool just_check) {
if (just_check) {
return _current_run_stage < _stage;
return _current_run_stage == _stage;
}
if (_current_run_stage < _stage) {
++_current_run_stage;
return true;
return false;
}
++_current_run_stage;
@ -109,12 +109,12 @@ bool ThreadPoolJob::should_do(const bool just_check) {
}
bool ThreadPoolJob::should_return() {
if (_cancelled)
return false;
if (!_limit_execution_time)
return true;
return get_current_execution_time() < _limit_execution_time;
if (!_limit_execution_time)
return false;
return get_current_execution_time() >= _limit_execution_time;
}
void ThreadPoolJob::execute() {