Searched refs:producer_thread (Results 1 – 2 of 2) sorted by relevance
95 ProducerThread producer_thread(buffer, &free_space, &used_space); in TEST() local97 producer_thread.Start(); in TEST()99 producer_thread.Join(); in TEST()
1360 producer_thread = ProducerThread(copy.copy(self), args_iterator, caller_id,1398 if producer_thread.unknown_exception:1400 raise producer_thread.unknown_exception1404 if producer_thread.iterator_exception and fail_on_error:1406 raise producer_thread.iterator_exception