Method operator()

examples/benchmark/static_thread_pool_bulk_enqueue.cpp:25–59

struct RunThread
{
  void operator()(exec::static_thread_pool& pool,
                  std::size_t               total_scheds,
                  std::size_t               tid,
                  std::barrier<>&           barrier,
#ifndef STDEXEC_NO_MONOTONIC_BUFFER_RESOURCE
                  std::span<char> buffer,
#endif
                  std::atomic<bool>& stop,
                  exec::numa_policy  numa)
  {
    int numa_node = numa.thread_index_to_node(tid);
    void(numa.bind_to_node(numa_node));
    while (true)
    {
      barrier.arrive_and_wait();
      if (stop.load())
      {
        break;
      }
#ifndef STDEXEC_NO_MONOTONIC_BUFFER_RESOURCE
      pmr::monotonic_buffer_resource   rsrc{buffer.data(), buffer.size()};
      pmr::polymorphic_allocator<char> alloc{&rsrc};
      auto                             env = stdexec::prop{stdexec::get_allocator, alloc};
      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() | stdexec::write_env(env);
#else
      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
      stdexec::sync_wait(iterate);
      barrier.arrive_and_wait();
    }
  }
};

struct my_numa_distribution : public exec::default_numa_policy