Searched refs:producerThread (Results 1 – 3 of 3) sorted by relevance
135 Future<?> producerThread = threadPool.submit(producer); in testDrainTimesOut() local147 producerThread.cancel(true); in testDrainTimesOut()
366 void producerThread (void* arg) in producerThread() function453 producer = deThread_create(producerThread, &testBuffer, DE_NULL); in deSemaphore_selfTest()