| /art/runtime/ |
| barrier.h | 17 // CAUTION: THIS IS NOT A FULLY GENERAL BARRIER API.
19 // It may either be used as a "latch" or single-use barrier, or it may be reused under
36 class Barrier {
43 explicit Barrier(int count);
44 virtual ~Barrier();
46 // Pass through the barrier, decrement the count but do not block.
49 // Wait on the barrier, decrement the count.
60 template <Barrier::LockHandling locks = kDisallowHoldingLocks>
76 // Counter, when this reaches 0 all people blocked on the barrier are signalled.
|
| barrier.cc | 17 #include "barrier.h"
28 Barrier::Barrier(int count)
30 lock_("GC barrier lock", kThreadSuspendCountLock),
31 condition_("GC barrier condition", lock_) {
34 template void Barrier::Increment<Barrier::kAllowHoldingLocks>(Thread* self, int delta);
35 template void Barrier::Increment<Barrier::kDisallowHoldingLocks>(Thread* self, int delta);
37 void Barrier::Pass(Thread* self)
[all...] |
| read_barrier-inl.h | 38 inline MirrorType* ReadBarrier::Barrier(
50 // the is_gray load to the ref field (ptr) load to avoid needing a load-load barrier between
92 LOG(FATAL) << "Unexpected read barrier type";
96 // No read barrier.
114 // TODO: separate the read barrier code from the collector code more.
140 LOG(FATAL) << "Unexpected read barrier type";
155 // TODO: separate the read barrier code from the collector code more.
189 // Only read-barrier configurations can have mutators run while
256 // Use a load-acquire to load the read barrier bit to avoid reordering with the subsequent load.
|
| /frameworks/base/libs/hwui/thread/ |
| Barrier.h | 25 class Barrier {
27 explicit Barrier(Condition::WakeUpType type = Condition::WAKE_UP_ALL)
29 ~Barrier() {}
|
| /frameworks/native/services/surfaceflinger/ |
| Barrier.h | 26 class Barrier
29 inline Barrier() : state(CLOSED) { }
30 inline ~Barrier() { }
32 // Release any threads waiting at the Barrier.
41 // Reset the Barrier, so wait() will block until open() has been called.
47 // Wait until the Barrier is OPEN.
|
| /external/antlr/antlr-3.4/tool/src/main/java/org/antlr/misc/ |
| Barrier.java | 30 /**A very simple barrier wait. Once a thread has requested a
31 * wait on the barrier with waitForRelease, it cannot fool the
32 * barrier into releasing by "hitting" the barrier multiple times--
35 public class Barrier {
39 public Barrier(int t) {
47 // The final thread to reach barrier resets barrier and
59 /** What to do when everyone reaches barrier */
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_thread.py | 134 class Barrier:
162 self.bar = Barrier(NUMTASKS)
174 # barrier before the others are all out
185 verbose_print("task %s leaving barrier" % ident)
|
| /external/python/cpython3/Lib/test/ |
| test_thread.py | 151 class Barrier:
179 self.bar = Barrier(NUMTASKS)
191 # barrier before the others are all out
202 verbose_print("task %s leaving barrier" % ident)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_thread.py | 157 class Barrier:
185 self.bar = Barrier(NUMTASKS)
197 # barrier before the others are all out
208 verbose_print("task %s leaving barrier" % ident)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_thread.py | 157 class Barrier:
185 self.bar = Barrier(NUMTASKS)
197 # barrier before the others are all out
208 verbose_print("task %s leaving barrier" % ident)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_thread.py | 157 class Barrier:
185 self.bar = Barrier(NUMTASKS)
197 # barrier before the others are all out
208 verbose_print("task %s leaving barrier" % ident)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_thread.py | 157 class Barrier:
185 self.bar = Barrier(NUMTASKS)
197 # barrier before the others are all out
208 verbose_print("task %s leaving barrier" % ident)
|
| /external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
| TensorDeviceThreadPool.h | 26 // Barrier is an object that allows one or more threads to wait until
28 class Barrier {
30 Barrier(unsigned int count) : state_(count << 1), notified_(false) {
33 ~Barrier() {
71 struct Notification : Barrier {
72 Notification() : Barrier(1) {};
90 static void run(Barrier* b, Function f, Args... args) {
159 EIGEN_STRONG_INLINE void enqueue_with_barrier(Barrier* b,
247 Barrier barrier(static_cast<unsigned int>(block_count))
[all...] |
| /external/google-benchmark/src/ |
| mutex.h | 99 class Barrier {
101 Barrier(int num_threads) : running_threads_(num_threads) {}
125 // State for barrier management
127 int entered_ = 0; // Number of threads that have entered this barrier
129 // Enter the barrier and wait until all other threads have also
130 // entered the barrier. Returns iff this is the last thread to
131 // enter the barrier.
146 // Last thread has reached the barrier
|
| /external/libcxx/utils/google-benchmark/src/ |
| mutex.h | 99 class Barrier {
101 Barrier(int num_threads) : running_threads_(num_threads) {}
125 // State for barrier management
127 int entered_ = 0; // Number of threads that have entered this barrier
129 // Enter the barrier and wait until all other threads have also
130 // entered the barrier. Returns iff this is the last thread to
131 // enter the barrier.
146 // Last thread has reached the barrier
|
| /external/python/cpython2/Lib/test/ |
| test_thread.py | 153 class Barrier:
181 self.bar = Barrier(NUMTASKS)
193 # barrier before the others are all out
204 verbose_print("task %s leaving barrier" % ident)
|
| /external/python/cpython3/Lib/multiprocessing/ |
| synchronize.py | 369 # Barrier
372 class Barrier(threading.Barrier):
|
| context.py | 94 def Barrier(self, parties, action=None, timeout=None):
95 '''Returns a barrier object'''
96 from .synchronize import Barrier
97 return Barrier(parties, action, timeout, ctx=self.get_context())
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/utils/google-benchmark/src/ |
| mutex.h | 99 class Barrier {
101 Barrier(int num_threads) : running_threads_(num_threads) {}
125 // State for barrier management
127 int entered_ = 0; // Number of threads that have entered this barrier
129 // Enter the barrier and wait until all other threads have also
130 // entered the barrier. Returns iff this is the last thread to
131 // enter the barrier.
146 // Last thread has reached the barrier
|
| /external/tensorflow/tensorflow/python/ops/ |
| data_flow_ops.py | [all...] |
| /external/valgrind/drd/tests/ |
| tsan_thread_wrappers_pthread.h | 554 class Barrier{
556 explicit Barrier(int n_threads) {CHECK(0 == pthread_barrier_init(&b_, 0, n_threads));}
557 ~Barrier() {CHECK(0 == pthread_barrier_destroy(&b_));}
559 // helgrind 3.3.0 does not have an interceptor for barrier.
|
| /external/deqp/external/vulkancts/modules/vulkan/tessellation/ |
| vktTessellationShaderInputOutputTests.cpp | 90 // No barrier needed, flushed memory is automatically visible
636 namespace Barrier
680 << " barrier();\n"
685 << " barrier();\n"
689 << " barrier();\n"
694 << " barrier();\n"
698 << " barrier();\n"
702 << " barrier();\n"
779 } // Barrier ns
855 // Barrier
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| barrier_ops.cc | 41 namespace barrier { namespace in namespace:tensorflow
43 class Barrier : public ResourceBase {
50 Barrier(const DataTypeVector& value_component_types,
118 "Barrier ", name_, " is closed. Pending enqueues cancelled: ",
146 "Barrier has had ", input_index_,
224 "Barrier '", name_, "' is closed and has ",
261 errors::Cancelled("Barrier '", name_, "' is already closed."));
297 ~Barrier() override EXCLUSIVE_LOCKS_REQUIRED(mu_) {
303 string DebugString() override { return "A barrier"; }
320 "Barrier ", name_
509 Barrier* barrier = nullptr; variable
[all...] |
| /external/python/cpython3/Lib/ |
| threading.py | 28 'Barrier', 'BrokenBarrierError', 'Timer', 'ThreadError',
555 # A barrier class. Inspired in part by the pthread_barrier_* api and
561 # We maintain two main states, 'filling' and 'draining' enabling the barrier
566 class Barrier:
567 """Implements a Barrier.
576 """Create a barrier, initialised to 'parties' threads.
579 the threads after they have all entered the barrier and just prior to
592 """Wait for the barrier.
595 simultaneously awoken. If an 'action' was provided for the barrier, one
603 self._enter() # Block while the barrier drains
[all...] |
| /external/swiftshader/third_party/LLVM/include/llvm/MC/ |
| MCInstrDesc.h | 103 Barrier,
298 return Flags & (1 << MCID::Barrier);
|
