| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/net/ |
| H A D | flow_control_channel.hpp | 67 size_t thread_count_; member in thrill::net::FlowControlChannel
174 assert(idx < thread_count_); in GetLocalShared()
203 return group_.num_hosts() * thread_count_; in num_workers()
259 for (size_t i = 0; i < thread_count_; i++) { in PrefixSumBase()
264 for (size_t i = 1; i < thread_count_; i++) { in PrefixSumBase()
374 for (size_t i = 0; i < thread_count_; ++i) { in ExPrefixSumTotal()
379 for (size_t i = 1; i < thread_count_; ++i) { in ExPrefixSumTotal()
437 size_t primary_pe = origin % thread_count_; in Broadcast()
441 group_.Broadcast(local, origin / thread_count_); in Broadcast()
670 if (local_id_ + 1 != thread_count_) { in Predecessor()
[all …]
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/tlx/tlx/ |
| H A D | thread_barrier_mutex.hpp | 32 : thread_count_(thread_count) { } in ThreadBarrierMutex()
48 if (counts_[current] < thread_count_) { in wait()
49 while (counts_[current] < thread_count_) { in wait()
82 const size_t thread_count_; member in tlx::ThreadBarrierMutex
|
| H A D | thread_barrier_spin.hpp | 36 : thread_count_(thread_count - 1) { } in ThreadBarrierSpin()
51 if (waiting_.fetch_add(1, std::memory_order_acq_rel) == thread_count_) { in wait()
80 if (waiting_.fetch_add(1, std::memory_order_acq_rel) == thread_count_) { in wait_yield()
103 const size_t thread_count_; member in tlx::ThreadBarrierSpin
|
| /dports/devel/tlx/tlx-0.5.20200222-5-g8982a9d/tlx/ |
| H A D | thread_barrier_mutex.hpp | 32 : thread_count_(thread_count) { } in ThreadBarrierMutex()
48 if (counts_[current] < thread_count_) { in wait()
49 while (counts_[current] < thread_count_) { in wait()
82 const size_t thread_count_; member in tlx::ThreadBarrierMutex
|
| H A D | thread_barrier_spin.hpp | 36 : thread_count_(thread_count - 1) { } in ThreadBarrierSpin()
51 if (waiting_.fetch_add(1, std::memory_order_acq_rel) == thread_count_) { in wait()
80 if (waiting_.fetch_add(1, std::memory_order_acq_rel) == thread_count_) { in wait_yield()
103 const size_t thread_count_; member in tlx::ThreadBarrierSpin
|
| /dports/cad/openroad/OpenROAD-2.0/src/sta/search/ |
| H A D | StaState.cc | 43 thread_count_(1), in StaState()
68 thread_count_(sta->thread_count_), in StaState()
95 thread_count_ = sta->thread_count_; in copyState()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/base/synchronization/ |
| H A D | condition_variable_unittest.cc | 136 const int thread_count_; member in base::__anonf142bc8f0111::WorkQueue
507 thread_count_(thread_count), in WorkQueue()
517 EXPECT_GE(thread_count_, 1); in WorkQueue()
522 for (int i = 0; i < thread_count_; ++i) { in WorkQueue()
536 for (int i = 0; i < thread_count_; ++i) { in ~WorkQueue()
621 for (int i = 0; i < thread_count_; ++i) { in ResetHistory()
629 for (int i = 0; i < thread_count_; ++i) in GetMinCompletionsByWorkerThread()
636 for (int i = 0; i < thread_count_; ++i) in GetMaxCompletionsByWorkerThread()
643 for (int i = 0; i < thread_count_; ++i) in GetNumThreadsTakingAssignments()
651 for (int i = 0; i < thread_count_; ++i) in GetNumThreadsCompletingTasks()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/synchronization/ |
| H A D | condition_variable_unittest.cc | 136 const int thread_count_; member in base::__anona513da8a0111::WorkQueue
507 thread_count_(thread_count), in WorkQueue()
517 EXPECT_GE(thread_count_, 1); in WorkQueue()
522 for (int i = 0; i < thread_count_; ++i) { in WorkQueue()
536 for (int i = 0; i < thread_count_; ++i) { in ~WorkQueue()
621 for (int i = 0; i < thread_count_; ++i) { in ResetHistory()
629 for (int i = 0; i < thread_count_; ++i) in GetMinCompletionsByWorkerThread()
636 for (int i = 0; i < thread_count_; ++i) in GetMaxCompletionsByWorkerThread()
643 for (int i = 0; i < thread_count_; ++i) in GetNumThreadsTakingAssignments()
651 for (int i = 0; i < thread_count_; ++i) in GetNumThreadsCompletingTasks()
[all …]
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp11/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
126 if (queue_.size() > thread_count_ * 16) in do_execute()
152 std::size_t thread_count_; member in fork_join_pool
|
| /dports/www/restbed/restbed-4.8/dependency/asio/asio/src/examples/cpp14/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
126 if (queue_.size() > thread_count_ * 16) in do_execute()
152 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/hyperscan/boost_1_75_0/libs/asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
126 if (queue_.size() > thread_count_ * 16) in do_execute()
152 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/hyperscan/boost_1_75_0/doc/html/boost_asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
126 if (queue_.size() > thread_count_ * 16) in do_execute()
152 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/hyperscan/boost_1_75_0/libs/asio/example/cpp14/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
126 if (queue_.size() > thread_count_ * 16) in do_execute()
152 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/boost-docs/boost_1_72_0/libs/asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 34 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
125 if (queue_.size() > thread_count_ * 16) in do_dispatch()
161 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/boost-python-libs/boost_1_72_0/libs/asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 34 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
125 if (queue_.size() > thread_count_ * 16) in do_dispatch()
161 std::size_t thread_count_; member in fork_join_pool
|
| /dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp14/executors/ |
| H A D | fork_join.cpp | 32 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
123 if (queue_.size() > thread_count_ * 16) in do_dispatch()
159 std::size_t thread_count_; member in fork_join_pool
|
| /dports/emulators/mess/mame-mame0226/3rdparty/asio/src/examples/cpp11/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
124 if (queue_.size() > thread_count_ * 16) in do_dispatch()
160 std::size_t thread_count_; member in fork_join_pool
|
| /dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp14/executors/ |
| H A D | fork_join.cpp | 32 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
123 if (queue_.size() > thread_count_ * 16) in do_dispatch()
159 std::size_t thread_count_; member in fork_join_pool
|
| /dports/emulators/mame/mame-mame0226/3rdparty/asio/src/examples/cpp11/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
124 if (queue_.size() > thread_count_ * 16) in do_dispatch()
160 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/boost-libs/boost_1_72_0/libs/asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 34 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
125 if (queue_.size() > thread_count_ * 16) in do_dispatch()
161 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/boost-libs/boost_1_72_0/doc/html/boost_asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 34 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
125 if (queue_.size() > thread_count_ * 16) in do_dispatch()
161 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/boost-docs/boost_1_72_0/doc/html/boost_asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 34 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
125 if (queue_.size() > thread_count_ * 16) in do_dispatch()
161 std::size_t thread_count_; member in fork_join_pool
|
| /dports/devel/boost-python-libs/boost_1_72_0/doc/html/boost_asio/example/cpp11/executors/ |
| H A D | fork_join.cpp | 34 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
125 if (queue_.size() > thread_count_ * 16) in do_dispatch()
161 std::size_t thread_count_; member in fork_join_pool
|
| /dports/net/asio/asio-1.16.0/src/examples/cpp11/executors/ |
| H A D | fork_join.cpp | 34 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
125 if (queue_.size() > thread_count_ * 16) in do_dispatch()
161 std::size_t thread_count_; member in fork_join_pool
|
| /dports/net/asio/asio-1.16.0/src/examples/cpp14/executors/ |
| H A D | fork_join.cpp | 33 for (thread_count_ = 0; thread_count_ < thread_count; ++thread_count_) in fork_join_pool()
124 if (queue_.size() > thread_count_ * 16) in do_dispatch()
160 std::size_t thread_count_; member in fork_join_pool
|