| /external/rust/crates/spin/src/ |
| D | barrier.rs | 45 pub struct Barrier<R = Spin> { struct
46 lock: Mutex<BarrierState, R>, argument
56 /// A `BarrierWaitResult` is returned by [`wait`] when all threads in the [`Barrier`] argument
72 impl<R: RelaxStrategy> Barrier<R> { impl
134 impl<R> Barrier<R> { impl
191 type Barrier = super::Barrier; typedef
193 fn use_barrier(n: usize, barrier: Arc<Barrier>) { in use_barrier()
|
| D | lib.rs | 112 pub type Barrier = crate::barrier::Barrier; typedef
|
| /external/rust/crates/tokio/src/sync/ |
| D | barrier.rs | 42 pub struct Barrier { struct
43 state: Mutex<BarrierState>, argument
57 impl Barrier { argument
63 pub fn new(mut n: usize) -> Barrier { in new()
|
| /external/libcxxabi/test/ |
| D | guard_threaded_test.pass.cpp | 135 struct Barrier { struct
136 explicit Barrier(int n) : m_wait_for(n) { reset(); } in Barrier() argument
139 void wait() { in wait()
148 int num_waiting() const { in num_waiting()
152 void reset() { in reset()
157 const int m_wait_for;
158 std::atomic<int> m_entered;
159 std::atomic<int> m_exited;
|
| /external/cronet/buildtools/third_party/libc++abi/trunk/test/ |
| D | guard_threaded_test.pass.cpp | 48 struct Barrier { struct
49 explicit Barrier(int n) : m_threads(n), m_remaining(n) { } in Barrier() function
53 void arrive_and_wait() const { in arrive_and_wait()
60 void arrive_and_drop() const { in arrive_and_drop()
64 void wait_for_threads(int n) const { in wait_for_threads()
71 const int m_threads;
72 mutable std::atomic<int> m_remaining;
|
| /external/antlr/tool/src/main/java/org/antlr/misc/ |
| D | Barrier.java | 35 public class Barrier { class
39 public Barrier(int t) { in Barrier() method in Barrier
|
| /external/skia/tests/ |
| D | SkStrikeTest.cpp | 43 class Barrier { class
45 Barrier(int threadCount) : fThreadCount(threadCount) { } in Barrier() function in Barrier
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/abseil-cpp/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/cronet/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | barrier.h | 53 explicit Barrier(int num_threads) in Barrier() function
|
| D | barrier_test.cc | 25 TEST(Barrier, SanityTest) { in TEST() argument
|
| /external/cronet/net/disk_cache/blockfile/ |
| D | file_lock.cc | 13 void Barrier() { in Barrier() function
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | Barrier.h | 20 Barrier(unsigned int count) : state_(count << 1), notified_(false) { in Barrier() function
|