make adl isolation of static_thread_pool consistent

NVIDIA · Jan 5, 2024 · 6467e29 · 6467e29
1 parent a21547c
commit 6467e29
Show file tree

Hide file tree

Showing 9 changed files with 1,276 additions and 1,226 deletions.
diff --git a/examples/benchmark/static_thread_pool.cpp b/examples/benchmark/static_thread_pool.cpp
@@ -44,7 +44,7 @@ struct RunThread {
       pmr::monotonic_buffer_resource resource{
         buffer.data(), buffer.size(), pmr::null_memory_resource()};
       pmr::polymorphic_allocator<char> alloc(&resource);
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
       auto env = exec::make_env(exec::with(stdexec::get_allocator, alloc));
@@ -62,7 +62,7 @@ struct RunThread {
         --scheds;
       }
 #else
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
       while (scheds) {

diff --git a/examples/benchmark/static_thread_pool_bulk_enqueue.cpp b/examples/benchmark/static_thread_pool_bulk_enqueue.cpp
@@ -43,11 +43,11 @@ struct RunThread {
       pmr::monotonic_buffer_resource rsrc{buffer.data(), buffer.size()};
       pmr::polymorphic_allocator<char> alloc{&rsrc};
       auto env = exec::make_env(exec::with(stdexec::get_allocator, alloc));
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::schedule_all(pool, std::views::iota(start, end))
                    | exec::ignore_all_values() | exec::write(env);
 #else
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::schedule_all(pool, std::views::iota(start, end))
                    | exec::ignore_all_values();
 #endif

diff --git a/examples/benchmark/static_thread_pool_bulk_enqueue_nested.cpp b/examples/benchmark/static_thread_pool_bulk_enqueue_nested.cpp
@@ -44,11 +44,11 @@ struct RunThread {
       pmr::monotonic_buffer_resource rsrc{buffer.data(), buffer.size()};
       pmr::polymorphic_allocator<char> alloc{&rsrc};
       auto env = exec::make_env(exec::with(stdexec::get_allocator, alloc));
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::iterate(std::views::iota(start, end)) | exec::ignore_all_values()
                    | exec::write(env);
 #else
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       auto iterate = exec::iterate(std::views::iota(start, end)) | exec::ignore_all_values();
 #endif
       stdexec::sync_wait(stdexec::on(scheduler, iterate));

diff --git a/examples/benchmark/static_thread_pool_nested.cpp b/examples/benchmark/static_thread_pool_nested.cpp
@@ -42,7 +42,7 @@ struct RunThread {
       pmr::monotonic_buffer_resource resource{
         buffer.data(), buffer.size(), pmr::null_memory_resource()};
       pmr::polymorphic_allocator<char> alloc(&resource);
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
       auto env = exec::make_env(exec::with(stdexec::get_allocator, alloc));
@@ -65,7 +65,7 @@ struct RunThread {
             }
           }));
 #else
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
       stdexec::sync_wait(

diff --git a/examples/benchmark/tbb_thread_pool.cpp b/examples/benchmark/tbb_thread_pool.cpp
@@ -42,7 +42,7 @@ struct RunThread {
       pmr::monotonic_buffer_resource resource{
         buffer.data(), buffer.size(), pmr::null_memory_resource()};
       pmr::polymorphic_allocator<char> alloc(&resource);
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
       auto env = exec::make_env(exec::with(stdexec::get_allocator, alloc));
@@ -60,7 +60,7 @@ struct RunThread {
         --scheds;
       }
 #else
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       std::atomic<std::size_t> counter{scheds};
       while (scheds) {

diff --git a/examples/benchmark/tbb_thread_pool_nested.cpp b/examples/benchmark/tbb_thread_pool_nested.cpp
@@ -40,7 +40,7 @@ struct RunThread {
       if (stop.load()) {
         break;
       }
-      auto [start, end] = exec::even_share(total_scheds, tid, pool.available_parallelism());
+      auto [start, end] = exec::_pool_::even_share(total_scheds, tid, pool.available_parallelism());
       std::size_t scheds = end - start;
       tbb::task_group tg{};
       stdexec::sync_wait(            //