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

Merge branch 'sleep_when_no_job_for_some_time' into 'master'

Browse Source 
TaskManager - sleep when no jobs for some time

See merge request ngsolve/netgen!571
This commit is contained in:
Schöberl, Joachim 2023-05-21 14:41:41 +02:00
commit c899273397
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 #endif
size_t no_job_counter = 0;
while (!done) while (!done)
{ {
if (complete[mynode] > jobdone) if (complete[mynode] > jobdone)
@ -492,11 +493,12 @@ namespace ngcore
if (jobnr == jobdone) if (jobnr == jobdone)
{ {
no_job_counter++;
// RegionTracer t(ti.thread_nr, tCASyield, ti.task_nr); // 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) if(sleep || no_job_counter > 10000)
std::this_thread::sleep_for(std::chrono::microseconds(sleep_usecs)); std::this_thread::sleep_for(std::chrono::microseconds(10));
else else
{ {
#ifdef WIN32 #ifdef WIN32
@ -537,6 +539,7 @@ namespace ngcore
ti.task_nr = mytasks.First()+mytask; ti.task_nr = mytasks.First()+mytask;
ti.ntasks = ntasks; ti.ntasks = ntasks;
no_job_counter = 0;
{ {
RegionTracer t(ti.thread_nr, jobnr, RegionTracer::ID_JOB, ti.task_nr); RegionTracer t(ti.thread_nr, jobnr, RegionTracer::ID_JOB, ti.task_nr);