Relintai/pandemonium_engine
1
0
Fork 0
mirror of https://github.com/Relintai/pandemonium_engine.git synced 2024-12-23 12:26:59 +01:00
Code Issues Packages Projects Releases Wiki Activity

Added virtual _execute to threadPoolJob.

Browse Source
This commit is contained in:
Relintai 2023-06-05 09:05:16 +02:00
parent 645045f97c
commit 9a2a39923a
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
core/os/thread_pool_job.cpp
View File

@ -107,18 +107,18 @@ bool ThreadPoolJob::should_do(const bool just_check) {
return true;
}
bool ThreadPoolJob::should_return() {
if (_cancelled)
if (_cancelled) {
return true;
}
if (_max_allocated_time < 0.00001)
if (_max_allocated_time < 0.00001) {
return false;
}
return get_current_execution_time() >= _max_allocated_time;
}
void ThreadPoolJob::execute() {
ERR_FAIL_COND(!has_method("_execute"));
_current_run_stage = 0;
_start_time = OS::get_singleton()->get_system_time_msecs();
@ -126,6 +126,12 @@ void ThreadPoolJob::execute() {
call("_execute");
}
void ThreadPoolJob::_execute() {
set_complete(true);
ERR_FAIL_MSG(get_class() + " ThreadPoolJob::_execute is not overridden!");
}
ThreadPoolJob::ThreadPoolJob() {
_complete = true;
_cancelled = false;
@ -181,6 +187,7 @@ void ThreadPoolJob::_bind_methods() {
BIND_VMETHOD(MethodInfo("_execute"));
ClassDB::bind_method(D_METHOD("execute"), &ThreadPoolJob::execute);
ClassDB::bind_method(D_METHOD("_execute"), &ThreadPoolJob::_execute);
ADD_SIGNAL(MethodInfo("completed"));
}

1
core/os/thread_pool_job.h
View File

@ -63,6 +63,7 @@ public:
bool should_return();
void execute();
virtual void _execute();
ThreadPoolJob();
~ThreadPoolJob();