Fix a few more tests to use thread_schedule_hint

STEllAR-GROUP · Mar 14, 2018 · 675d49a · 675d49a
1 parent d848a8b
commit 675d49a
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 10 deletions.
diff --git a/tests/performance/local/htts_v2/htts2_hpx.cpp b/tests/performance/local/htts_v2/htts2_hpx.cpp
@@ -85,7 +85,7 @@ struct hpx_driver : htts2::driver
               , nullptr // No HPX-thread name.
               , hpx::threads::pending
               , hpx::threads::thread_priority_normal
-              , target_osthread // Place in the target OS-thread's queue.
+              , hpx::threads::thread_schedule_hint(target_osthread) // Place in the target OS-thread's queue.
                 );
         }
 
@@ -97,9 +97,8 @@ struct hpx_driver : htts2::driver
                     std::ref(*this), _1)
               , nullptr // No HPX-thread name.
               , hpx::threads::pending
-              , false // Do not run immediately.
               , hpx::threads::thread_priority_normal
-              , target_osthread // Place in the target OS-thread's queue.
+              , hpx::threads::thread_schedule_hint(target_osthread) // Place in the target OS-thread's queue.
                 );
         }
     }
@@ -156,7 +155,7 @@ struct hpx_driver : htts2::driver
               , nullptr // No HPX-thread name.
               , hpx::threads::pending
               , hpx::threads::thread_priority_normal
-              , i // Place in the target OS-thread's queue.
+              , hpx::threads::thread_schedule_hint(i) // Place in the target OS-thread's queue.
                 );
         }
 

diff --git a/tests/performance/local/timed_task_spawn.cpp b/tests/performance/local/timed_task_spawn.cpp
@@ -233,15 +233,15 @@ void stage_worker_static_balanced_stackbased(
           , "invoke_worker_timed_suspension"
           , hpx::threads::pending
           , hpx::threads::thread_priority_normal
-          , target_thread
+          , hpx::threads::thread_schedule_hint(target_thread)
             );
     else
         hpx::threads::register_thread_plain(
             &invoke_worker_timed_no_suspension
           , "invoke_worker_timed_no_suspension"
           , hpx::threads::pending
           , hpx::threads::thread_priority_normal
-          , target_thread
+          , hpx::threads::thread_schedule_hint(target_thread)
             );
 }
 
@@ -256,15 +256,15 @@ void stage_worker_static_imbalanced(
           , "invoke_worker_timed_suspension"
           , hpx::threads::pending
           , hpx::threads::thread_priority_normal
-          , 0
+          , hpx::threads::thread_schedule_hint(0)
             );
     else
         hpx::threads::register_thread_plain(
             &invoke_worker_timed_no_suspension
           , "invoke_worker_timed_no_suspension"
           , hpx::threads::pending
           , hpx::threads::thread_priority_normal
-          , 0
+          , hpx::threads::thread_schedule_hint(0)
             );
 }
 
@@ -304,7 +304,7 @@ void stage_workers(
             , "stage_workers"
             , hpx::threads::pending
             , hpx::threads::thread_priority_normal
-            , target_thread
+            , hpx::threads::thread_schedule_hint(target_thread)
               );
         return;
     }
@@ -456,7 +456,7 @@ int hpx_main(
                 , "stage_workers"
                 , hpx::threads::pending
                 , hpx::threads::thread_priority_normal
-                , i
+                , hpx::threads::thread_schedule_hint(i)
                   );
         }