Searched refs:workToBeDone (Results 1 – 1 of 1) sorted by relevance
39 private Semaphore workToBeDone; field in StreamConsumer55 workToBeDone = new Semaphore(0); in StreamConsumer()73 workToBeDone.release(); in giveStreamAndStartConsuming()109 workToBeDone.release(); in shutdown()157 workToBeDone.acquire(); in run()