/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | Semaphore.java | 109 * initialized as fair, to ensure that no thread is starved out from 111 * synchronization control, the throughput advantages of non-fair 122 * fair mode. 140 * to represent permits. Subclassed into fair and nonfair 252 * @param fair {@code true} if this semaphore will guarantee 256 public Semaphore(int permits, boolean fair) { argument 257 sync = fair ? new FairSync(permits) : new NonfairSync(permits); 327 * fair ordering policy, a call to {@code tryAcquire()} <em>will</em> 490 * <p>Even when this semaphore has been set to use a fair ordering
|
H A D | ArrayBlockingQueue.java | 204 * @param fair if {@code true} then queue accesses for threads blocked 209 public ArrayBlockingQueue(int capacity, boolean fair) { argument 213 lock = new ReentrantLock(fair); 225 * @param fair if {@code true} then queue accesses for threads blocked 234 public ArrayBlockingQueue(int capacity, boolean fair, argument 236 this(capacity, fair);
|
H A D | SynchronousQueue.java | 70 * The (Lifo) stack is used for non-fair mode, and the (Fifo) 71 * queue for fair mode. The performance of the two is generally 828 * @param fair if true, waiting threads contend in FIFO order for 831 public SynchronousQueue(boolean fair) { argument 832 transferer = fair ? new TransferQueue<E>() : new TransferStack<E>(); 1144 boolean fair = transferer instanceof TransferQueue; 1145 if (fair) {
|
/libcore/luni/src/main/java/java/util/concurrent/locks/ |
H A D | ReentrantLock.java | 31 * access order. Programs using fair locks accessed by many threads 37 * fair lock may obtain it multiple times in succession while other 86 * into fair and nonfair versions below. Uses AQS state to 99 * Performs non-fair tryLock. tryAcquire is implemented in 171 * Sync object for non-fair locks 194 * Sync object for fair locks 241 * @param fair {@code true} if this lock should use a fair ordering policy 243 public ReentrantLock(boolean fair) { argument 244 sync = fair [all...] |
H A D | ReentrantReadWriteLock.java | 25 * <dt><b><i>Non-fair mode (default)</i></b> 27 * When constructed as non-fair (the default), the order of entry 31 * will normally have higher throughput than a fair lock. 35 * When constructed as fair, threads contend for entry using an 42 * <p>A thread that tries to acquire a fair read lock (non-reentrantly) 51 * <p>A thread that tries to acquire a fair write lock (non-reentrantly) 55 * do not honor this fair setting and will immediately acquire the lock 210 * @param fair {@code true} if this lock should use a fair ordering policy 212 public ReentrantReadWriteLock(boolean fair) { argument [all...] |
/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | SynchronousQueueTest.java | 60 public void testEmptyFull(boolean fair) { argument 61 final SynchronousQueue q = new SynchronousQueue(fair); 73 public void testOffer(boolean fair) { argument 74 SynchronousQueue q = new SynchronousQueue(fair); 83 public void testAdd(boolean fair) { argument 84 SynchronousQueue q = new SynchronousQueue(fair); 97 public void testAddAll_self(boolean fair) { argument 98 SynchronousQueue q = new SynchronousQueue(fair); 110 public void testAddAll_ISE(boolean fair) { argument 111 SynchronousQueue q = new SynchronousQueue(fair); 127 testBlockingPut(boolean fair) argument 159 testPutWithTake(boolean fair) argument 193 testTimedOffer(boolean fair) argument 219 testPoll(boolean fair) argument 229 testTimedPoll0(boolean fair) argument 240 testTimedPoll(boolean fair) argument 254 testTimedPollWithOffer(boolean fair) argument 302 testPeek(boolean fair) argument 312 testElement(boolean fair) argument 325 testRemove(boolean fair) argument 338 testContains(boolean fair) argument 348 testClear(boolean fair) argument 359 testContainsAll(boolean fair) argument 372 testRetainAll(boolean fair) argument 385 testRemoveAll(boolean fair) argument 398 testToArray(boolean fair) argument 410 testToArray2(boolean fair) argument 431 testToArray_null(boolean fair) argument 444 testIterator(boolean fair) argument 453 testIteratorRemove(boolean fair) argument 467 testToString(boolean fair) argument 478 testOfferInExecutor(boolean fair) argument 505 testPollInExecutor(boolean fair) argument 552 testDrainTo(boolean fair) argument 565 testDrainToWithActivePut(boolean fair) argument [all...] |
H A D | SemaphoreTest.java | 37 PublicSemaphore(int permits, boolean fair) { super(permits, fair); } argument 160 public void testConstructor(boolean fair) { argument 162 Semaphore s = new Semaphore(permits, fair); 164 assertEquals(fair, s.isFair()); 184 public void testTryAcquireInSameThread(boolean fair) { argument 185 Semaphore s = new Semaphore(2, fair); 200 public void testTryAcquire_timeout(boolean fair) { argument 201 Semaphore s = new Semaphore(0, fair); 213 public void testTryAcquireN_timeout(boolean fair) { argument 233 testInterruptible(boolean fair, final AcquireMethod acquirer) argument 283 testUninterruptible(boolean fair, final AcquireMethod acquirer) argument 323 testHasQueuedThreads(boolean fair) argument 346 testGetQueueLength(boolean fair) argument 369 testGetQueuedThreads(boolean fair) argument 395 testDrainPermits(boolean fair) argument 411 testReleaseIAE(boolean fair) argument 424 testReducePermitsIAE(boolean fair) argument 437 testReducePermits(boolean fair) argument 458 testSerialization(boolean fair) argument 503 testTryAcquireNInSameThread(boolean fair) argument 534 testReleaseAcquireSameThread(boolean fair, final AcquireMethod acquirer) argument 562 testReleaseAcquireDifferentThreads(boolean fair, final AcquireMethod acquirer) argument 636 testToString(boolean fair) argument [all...] |
H A D | ReentrantLockTest.java | 64 PublicReentrantLock(boolean fair) { super(fair); } argument 204 public void testLock(boolean fair) { argument 205 PublicReentrantLock lock = new PublicReentrantLock(fair); 216 public void testUnlock_IMSE(boolean fair) { argument 217 ReentrantLock lock = new ReentrantLock(fair); 229 public void testTryLock(boolean fair) { argument 230 PublicReentrantLock lock = new PublicReentrantLock(fair); 244 public void testHasQueuedThreads(boolean fair) { argument 245 final PublicReentrantLock lock = new PublicReentrantLock(fair); 270 testGetQueueLength(boolean fair) argument 295 testHasQueuedThreadNPE(boolean fair) argument 308 testHasQueuedThread(boolean fair) argument 338 testGetQueuedThreads(boolean fair) argument 369 testTryLock_Interruptible(boolean fair) argument 388 testTryLockWhenLocked(boolean fair) argument 405 testTryLock_Timeout(boolean fair) argument 425 testGetHoldCount(boolean fair) argument 442 testIsLocked(boolean fair) argument 477 testLockInterruptibly(boolean fair) argument 497 testAwait_IMSE(boolean fair) argument 516 testSignal_IMSE(boolean fair) argument 530 testAwaitNanos_Timeout(boolean fair) argument 550 testAwait_Timeout(boolean fair) argument 568 testAwaitUntil_Timeout(boolean fair) argument 587 testAwait(boolean fair) argument 614 testHasWaitersNPE(boolean fair) argument 627 testGetWaitQueueLengthNPE(boolean fair) argument 640 testGetWaitingThreadsNPE(boolean fair) argument 653 testHasWaitersIAE(boolean fair) argument 668 testHasWaitersIMSE(boolean fair) argument 682 testGetWaitQueueLengthIAE(boolean fair) argument 697 testGetWaitQueueLengthIMSE(boolean fair) argument 711 testGetWaitingThreadsIAE(boolean fair) argument 726 testGetWaitingThreadsIMSE(boolean fair) argument 740 testHasWaiters(boolean fair) argument 773 testGetWaitQueueLength(boolean fair) argument 831 testGetWaitingThreads(boolean fair) argument 891 testAwaitUninterruptibly(boolean fair) argument 944 testInterruptible(boolean fair, final AwaitMethod awaitMethod) argument 983 testSignalAll(boolean fair, final AwaitMethod awaitMethod) argument 1014 testSignalWakesFifo(boolean fair) argument 1061 testAwaitLockCount(boolean fair) argument 1107 testSerialization(boolean fair) argument 1133 testToString(boolean fair) argument [all...] |
H A D | ReentrantReadWriteLockTest.java | 65 PublicReentrantReadWriteLock(boolean fair) { super(fair); } argument 216 public void testLock(boolean fair) { argument 218 new PublicReentrantReadWriteLock(fair); 238 public void testGetWriteHoldCount(boolean fair) { argument 239 ReentrantReadWriteLock lock = new ReentrantReadWriteLock(fair); 255 public void testGetHoldCount(boolean fair) { argument 256 ReentrantReadWriteLock lock = new ReentrantReadWriteLock(fair); 272 public void testGetReadHoldCount(boolean fair) { argument 273 ReentrantReadWriteLock lock = new ReentrantReadWriteLock(fair); 289 testWriteUnlock_IMSE(boolean fair) argument 302 testReadUnlock_IMSE(boolean fair) argument 315 testWriteLockInterruptibly_Interruptible(boolean fair) argument 335 testWriteTryLock_Interruptible(boolean fair) argument 355 testReadLockInterruptibly_Interruptible(boolean fair) argument 375 testReadTryLock_Interruptible(boolean fair) argument 395 testWriteTryLock(boolean fair) argument 411 testWriteTryLockWhenLocked(boolean fair) argument 429 testReadTryLockWhenLocked(boolean fair) argument 447 testMultipleReadLocks(boolean fair) argument 469 testWriteAfterReadLock(boolean fair) argument 494 testWriteAfterMultipleReadLocks(boolean fair) argument 567 testReadAfterWriteLock(boolean fair) argument 594 testReadHoldingWriteLock(boolean fair) argument 608 testReadTryLockBarging(boolean fair) argument 651 testReadHoldingWriteLock2(boolean fair) argument 685 testReadHoldingWriteLock3(boolean fair) argument 720 testWriteHoldingWriteLock4(boolean fair) argument 758 testTryLockWhenReadLocked(boolean fair) argument 776 testWriteTryLockWhenReadLocked(boolean fair) argument 793 testWriteTryLock_Timeout(boolean fair) argument 814 testReadTryLock_Timeout(boolean fair) argument 835 testWriteLockInterruptibly(boolean fair) argument 858 testReadLockInterruptibly(boolean fair) argument 882 testAwait_IMSE(boolean fair) argument 903 testSignal_IMSE(boolean fair) argument 917 testSignalAll_IMSE(boolean fair) argument 931 testAwaitNanos_Timeout(boolean fair) argument 952 testAwait_Timeout(boolean fair) argument 971 testAwaitUntil_Timeout(boolean fair) argument 991 testAwait(boolean fair) argument 1019 testAwaitUninterruptibly(boolean fair) argument 1072 testInterruptible(boolean fair, final AwaitMethod awaitMethod) argument 1111 testSignalAll(boolean fair, final AwaitMethod awaitMethod) argument 1144 testSignalWakesFifo(boolean fair) argument 1192 testAwaitLockCount(boolean fair) argument 1238 testSerialization(boolean fair) argument 1265 testHasQueuedThreads(boolean fair) argument 1292 testHasQueuedThreadNPE(boolean fair) argument 1305 testHasQueuedThread(boolean fair) argument 1336 testGetQueueLength(boolean fair) argument 1362 testGetQueuedThreads(boolean fair) argument 1394 testHasWaitersNPE(boolean fair) argument 1407 testGetWaitQueueLengthNPE(boolean fair) argument 1420 testGetWaitingThreadsNPE(boolean fair) argument 1433 testHasWaitersIAE(boolean fair) argument 1448 testHasWaitersIMSE(boolean fair) argument 1462 testGetWaitQueueLengthIAE(boolean fair) argument 1477 testGetWaitQueueLengthIMSE(boolean fair) argument 1491 testGetWaitingThreadsIAE(boolean fair) argument 1508 testGetWaitingThreadsIMSE(boolean fair) argument 1523 testHasWaiters(boolean fair) argument 1557 testGetWaitQueueLength(boolean fair) argument 1587 testGetWaitingThreads(boolean fair) argument 1640 testToString(boolean fair) argument 1659 testReadLockToString(boolean fair) argument 1672 testWriteLockToString(boolean fair) argument [all...] |