Searched refs:semaphore (Results 1 – 2 of 2) sorted by relevance
295 private final Semaphore semaphore; field in Main.QueuedWait297 public QueuedWait(Semaphore semaphore) { in QueuedWait() argument298 this.semaphore = semaphore; in QueuedWait()305 semaphore.acquire(); in perform()320 semaphore.release(); in perform()328 Semaphore semaphore) { in createDefaultFrequencyMap() argument341 frequencyMap.put(new QueuedWait(semaphore), 0.05); // 10/200 in createDefaultFrequencyMap()373 Object lock, Semaphore semaphore, String arg) { in updateFrequencyMap() argument413 op = new QueuedWait(semaphore); in updateFrequencyMap()480 Semaphore semaphore = getSemaphore(permits); in parseAndRun() local[all …]
102 semaphore = threading.Semaphore(1) variable239 global semaphore240 semaphore = threading.Semaphore(n_thread)502 semaphore.acquire()593 semaphore.release()