SemaphoreTest.java 文件源码

public void testReleaseAcquireSameThread(boolean fair,
                                         final AcquireMethod acquirer) {
    Semaphore s = new Semaphore(1, fair);
    for (int i = 1; i < 6; i++) {
        s.release(i);
        assertEquals(1 + i, s.availablePermits());
        try {
            acquirer.acquire(s, i);
        } catch (InterruptedException e) { threadUnexpectedException(e); }
        assertEquals(1, s.availablePermits());
    }
}