Lines Matching refs:semaphore

295         private final Semaphore semaphore;  field in Main.QueuedWait
297 public QueuedWait(Semaphore semaphore) { in QueuedWait() argument
298 this.semaphore = semaphore; in QueuedWait()
305 semaphore.acquire(); in perform()
320 semaphore.release(); in perform()
328 Semaphore semaphore) { in createDefaultFrequencyMap() argument
341 frequencyMap.put(new QueuedWait(semaphore), 0.05); // 10/200 in createDefaultFrequencyMap()
373 Object lock, Semaphore semaphore, String arg) { in updateFrequencyMap() argument
413 op = new QueuedWait(semaphore); in updateFrequencyMap()
480 Semaphore semaphore = getSemaphore(permits); in parseAndRun() local
481 frequencyMap = updateFrequencyMap(frequencyMap, lock, semaphore, args[i]); in parseAndRun()
508 Semaphore semaphore = getSemaphore(permits); in parseAndRun() local
509 frequencyMap = createDefaultFrequencyMap(lock, semaphore); in parseAndRun()
532 Semaphore semaphore = new Semaphore(permits, /* fair */ true); in getSemaphore() local
533 forceTransitiveClassInitialization(semaphore, permits); in getSemaphore()
534 return semaphore; in getSemaphore()
543 private static void forceTransitiveClassInitialization(Semaphore semaphore, final int permits) { in forceTransitiveClassInitialization() argument
546 assert semaphore.availablePermits() == permits; in forceTransitiveClassInitialization()
560 semaphore.acquire(); in forceTransitiveClassInitialization()
563 semaphore.release(); in forceTransitiveClassInitialization()
573 semaphore.acquire(permits); in forceTransitiveClassInitialization()
579 while (!semaphore.hasQueuedThreads()) { in forceTransitiveClassInitialization()
584 semaphore.release(); in forceTransitiveClassInitialization()
588 semaphore.release(permits - 1); in forceTransitiveClassInitialization()
591 assert semaphore.availablePermits() == permits; in forceTransitiveClassInitialization()