Searched refs:Semaphore (Results 1 – 6 of 6) sorted by relevance
15 import java.util.concurrent.Semaphore;35 static class PublicSemaphore extends Semaphore {53 final Semaphore lock;54 InterruptibleLockRunnable(Semaphore s) { lock = s; } in InterruptibleLockRunnable()67 final Semaphore lock;68 InterruptedLockRunnable(Semaphore s) { lock = s; } in InterruptedLockRunnable()91 void waitForQueuedThreads(Semaphore s) { in waitForQueuedThreads()102 void acquire(Semaphore s) throws InterruptedException { in acquire()107 void acquire(Semaphore s, int permits) throws InterruptedException { in acquireN()112 void acquire(Semaphore s) { in acquireUninterruptibly()[all …]
50 import java.util.concurrent.Semaphore;1520 public void await(Semaphore semaphore) {
162 public class Semaphore implements java.io.Serializable { class270 public Semaphore(int permits) { in Semaphore() method in Semaphore285 public Semaphore(int permits, boolean fair) { in Semaphore() method in Semaphore
22 import java.util.concurrent.Semaphore;312 final Semaphore sem = new Semaphore(0); in test_getState()
48 import java.util.concurrent.Semaphore;392 private final Semaphore connectionAttempts = new Semaphore(0);
974 "ojluni/src/main/java/java/util/concurrent/Semaphore.java",