Searched refs:blocking_counter (Results 1 – 2 of 2) sorted by relevance
26 Thread(BlockingCounter* blocking_counter, int number_of_times_to_decrement) in Thread() argument27 : blocking_counter_(blocking_counter), in Thread()61 void test_blocking_counter(BlockingCounter* blocking_counter, int num_threads, in test_blocking_counter() argument65 blocking_counter->Reset(num_decrements_to_wait_for); in test_blocking_counter()67 threads.push_back(new Thread(blocking_counter, num_decrements_per_thread)); in test_blocking_counter()69 blocking_counter->Wait(); in test_blocking_counter()82 BlockingCounter* blocking_counter = new BlockingCounter; in test_blocking_counter() local91 test_blocking_counter(blocking_counter, num_threads, in test_blocking_counter()97 delete blocking_counter; in test_blocking_counter()
6028 BlockingCounter *blocking_counter; variable6031 CHECK(blocking_counter); in Worker()6033 blocking_counter->DecrementCount(); in Worker()6038 blocking_counter = new BlockingCounter(3); in Run()6040 blocking_counter->Wait(); in Run()7147 BlockingCounter *blocking_counter; variable