Searched refs:blocking_counter (Results 1 – 3 of 3) sorted by relevance
| /external/gemmlowp/test/ |
| D | test_blocking_counter.cc | 26 Thread(BlockingCounter* blocking_counter, int number_of_times_to_decrement) in Thread() argument
27 : blocking_counter_(blocking_counter), in Thread()
66 void test_blocking_counter(BlockingCounter* blocking_counter, int num_threads, in test_blocking_counter() argument
70 blocking_counter->Reset(num_decrements_to_wait_for); in test_blocking_counter()
72 threads.push_back(new Thread(blocking_counter, num_decrements_per_thread)); in test_blocking_counter()
74 blocking_counter->Wait(); in test_blocking_counter()
87 BlockingCounter* blocking_counter = new BlockingCounter; in test_blocking_counter() local
96 test_blocking_counter(blocking_counter, num_threads, in test_blocking_counter()
102 delete blocking_counter; in test_blocking_counter()
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | context.cc | 310 BlockingCounter blocking_counter(static_cast<int>(remote_contexts_.size())); in MaybeRegisterFunctionRemotely()
327 [i, &statuses, &blocking_counter](const Status& status) { in MaybeRegisterFunctionRemotely()
329 blocking_counter.DecrementCount(); in MaybeRegisterFunctionRemotely()
334 blocking_counter.Wait(); in MaybeRegisterFunctionRemotely()
|
| /external/tensorflow/tensorflow/core/ |
| D | BUILD | 2278 "lib/core/blocking_counter.h",
|