• Home
  • Raw
  • Download

Lines Matching refs:semaphore

281         private final Semaphore semaphore;  field in Main.QueuedWait
283 public QueuedWait(Semaphore semaphore) { in QueuedWait() argument
284 this.semaphore = semaphore; in QueuedWait()
291 semaphore.acquire(); in perform()
306 semaphore.release(); in perform()
314 Semaphore semaphore) { in createDefaultFrequencyMap() argument
328 frequencyMap.put(new QueuedWait(semaphore), 0.05); // 10/200 in createDefaultFrequencyMap()
359 Object lock, Semaphore semaphore, String arg) { in updateFrequencyMap() argument
395 op = new QueuedWait(semaphore); in updateFrequencyMap()
462 Semaphore semaphore = getSemaphore(permits); in parseAndRun() local
463 frequencyMap = updateFrequencyMap(frequencyMap, lock, semaphore, args[i]); in parseAndRun()
490 Semaphore semaphore = getSemaphore(permits); in parseAndRun() local
491 frequencyMap = createDefaultFrequencyMap(lock, semaphore); in parseAndRun()
514 Semaphore semaphore = new Semaphore(permits, /* fair */ true); in getSemaphore() local
515 forceTransitiveClassInitialization(semaphore, permits); in getSemaphore()
516 return semaphore; in getSemaphore()
525 private static void forceTransitiveClassInitialization(Semaphore semaphore, final int permits) { in forceTransitiveClassInitialization() argument
528 assert semaphore.availablePermits() == permits; in forceTransitiveClassInitialization()
542 semaphore.acquire(); in forceTransitiveClassInitialization()
545 semaphore.release(); in forceTransitiveClassInitialization()
555 semaphore.acquire(permits); in forceTransitiveClassInitialization()
561 while (!semaphore.hasQueuedThreads()) { in forceTransitiveClassInitialization()
566 semaphore.release(); in forceTransitiveClassInitialization()
570 semaphore.release(permits - 1); in forceTransitiveClassInitialization()
573 assert semaphore.availablePermits() == permits; in forceTransitiveClassInitialization()