Searched refs:consumer_thread (Results 1 – 2 of 2) sorted by relevance
174 static void consumer_thread(void* arg) { in consumer_thread() function237 i < producers ? producer_thread : consumer_thread, options + i, &ok); in test_threading()
188 def consumer_thread(): function196 self.checkedThread(consumer_thread) for _ in range(num_threads)227 def consumer_thread(): function233 self.checkedThread(consumer_thread) for _ in range(num_threads)