Searched refs:fair (Results 1 - 9 of 9) sorted by relevance

/libcore/jsr166-tests/src/test/java/jsr166/
H A DSynchronousQueueTest.java60 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 DReentrantReadWriteLockTest.java65 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...]
H A DSemaphoreTest.java37 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 DReentrantLockTest.java64 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...]
/libcore/ojluni/src/main/java/java/util/concurrent/
H A DSemaphore.java138 * initialized as fair, to ensure that no thread is starved out from
140 * synchronization control, the throughput advantages of non-fair
151 * fair mode.
169 * to represent permits. Subclassed into fair and nonfair
281 * @param fair {@code true} if this semaphore will guarantee
285 public Semaphore(int permits, boolean fair) { argument
286 sync = fair ? new FairSync(permits) : new NonfairSync(permits);
356 * fair ordering policy, a call to {@code tryAcquire()} <em>will</em>
519 * <p>Even when this semaphore has been set to use a fair ordering
H A DArrayBlockingQueue.java233 * @param fair if {@code true} then queue accesses for threads blocked
238 public ArrayBlockingQueue(int capacity, boolean fair) { argument
242 lock = new ReentrantLock(fair);
254 * @param fair if {@code true} then queue accesses for threads blocked
263 public ArrayBlockingQueue(int capacity, boolean fair, argument
265 this(capacity, fair);
H A DSynchronousQueue.java99 * The (Lifo) stack is used for non-fair mode, and the (Fifo)
100 * queue for fair mode. The performance of the two is generally
857 * @param fair if true, waiting threads contend in FIFO order for
860 public SynchronousQueue(boolean fair) { argument
861 transferer = fair ? new TransferQueue<E>() : new TransferStack<E>();
1173 boolean fair = transferer instanceof TransferQueue;
1174 if (fair) {
/libcore/ojluni/src/main/java/java/util/concurrent/locks/
H A DReentrantLock.java59 * access order. Programs using fair locks accessed by many threads
65 * fair lock may obtain it multiple times in succession while other
114 * into fair and nonfair versions below. Uses AQS state to
127 * Performs non-fair tryLock. tryAcquire is implemented in
197 * Sync object for non-fair locks
219 * Sync object for fair locks
265 * @param fair {@code true} if this lock should use a fair ordering policy
267 public ReentrantLock(boolean fair) { argument
268 sync = fair
[all...]
H A DReentrantReadWriteLock.java54 * <dt><b><i>Non-fair mode (default)</i></b>
56 * When constructed as non-fair (the default), the order of entry
60 * will normally have higher throughput than a fair lock.
64 * When constructed as fair, threads contend for entry using an
71 * <p>A thread that tries to acquire a fair read lock (non-reentrantly)
80 * <p>A thread that tries to acquire a fair write lock (non-reentrantly)
84 * do not honor this fair setting and will immediately acquire the lock
239 * @param fair {@code true} if this lock should use a fair ordering policy
241 public ReentrantReadWriteLock(boolean fair) { argument
[all...]

Completed in 212 milliseconds