@@ -441,14 +441,10 @@ class Runtime
441441 */
442442 __INLINE__ void addService (taskr::service_t *service) { _serviceQueue->push (service); }
443443
444-
445444 /* *
446445 * Funtion to force termination in case the application does not have its own termination logic
447446 */
448- __INLINE__ void forceTermination ()
449- {
450- _forceTerminate = true ;
451- }
447+ __INLINE__ void forceTermination () { _forceTerminate = true ; }
452448
453449 private:
454450
@@ -461,7 +457,7 @@ class Runtime
461457
462458 // Getting worker pointer
463459 auto worker = _serviceWorkers[serviceWorkerId];
464-
460+
465461 // Checking for termination
466462 auto terminated = checkTermination (worker.get ());
467463
@@ -507,16 +503,16 @@ class Runtime
507503 if (_forceTerminate == true )
508504 {
509505 while (_commonReadyTaskQueue->wasEmpty () == false )
510- {
506+ {
511507 auto task = _commonReadyTaskQueue->pop ();
512508 if (task != nullptr ) _activeTaskCount--;
513- }
509+ }
514510
515511 while (worker->getReadyTaskQueue ()->wasEmpty () == false )
516- {
512+ {
517513 auto task = worker->getReadyTaskQueue ()->pop ();
518514 if (task != nullptr ) _activeTaskCount--;
519- }
515+ }
520516 }
521517
522518 // If required, perform a service task
@@ -739,8 +735,6 @@ class Runtime
739735 this ->_workerCallbackMap .trigger (taskrWorker, HiCR::tasking::Worker::callback_t ::onWorkerTerminate);
740736 }
741737
742-
743-
744738 /* *
745739 * Flag to indicate whether execution must be forcibly terminated. It is discouraged to use this if the application
746740 * has implemented a clear ending logic. This is only useful for always-on services-like applications
0 commit comments