ForkMaster/netgen
1
0
Fork 0
mirror of https://github.com/NGSolve/netgen.git synced 2024-11-11 16:49:16 +05:00
Code Issues Packages Projects Releases Wiki Activity

TaskManager - sleep when no jobs for some time

Browse Source
This commit is contained in:
Hochsteger, Matthias 2023-05-21 14:41:41 +02:00 committed by Schöberl, Joachim
parent f802197576
commit a1b43088a4
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
libsrc/core/taskmanager.cpp
View File

@ -485,6 +485,7 @@ namespace ngcore
#endif
size_t no_job_counter = 0;
while (!done)
{
if (complete[mynode] > jobdone)
@ -492,11 +493,12 @@ namespace ngcore
if (jobnr == jobdone)
{
no_job_counter++;
// RegionTracer t(ti.thread_nr, tCASyield, ti.task_nr);
while (ProcessTask()); // do the nested tasks
while (ProcessTask()) no_job_counter = 0; // do the nested tasks
if(sleep)
std::this_thread::sleep_for(std::chrono::microseconds(sleep_usecs));
if(sleep || no_job_counter > 10000)
std::this_thread::sleep_for(std::chrono::microseconds(10));
else
{
#ifdef WIN32
@ -537,6 +539,7 @@ namespace ngcore
ti.task_nr = mytasks.First()+mytask;
ti.ntasks = ntasks;
no_job_counter = 0;
{
RegionTracer t(ti.thread_nr, jobnr, RegionTracer::ID_JOB, ti.task_nr);