Home | History | Annotate | Download | only in concurrent

Lines Matching refs:sync

165     private final Sync sync;
172 abstract static class Sync extends AbstractQueuedSynchronizer {
175 Sync(int permits) {
227 static final class NonfairSync extends Sync {
242 static final class FairSync extends Sync {
271 sync = new NonfairSync(permits);
286 sync = fair ? new FairSync(permits) : new NonfairSync(permits);
318 sync.acquireSharedInterruptibly(1);
341 sync.acquireShared(1);
369 return sync.nonfairTryAcquireShared(1) >= 0;
415 return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
432 sync.releaseShared(1);
475 sync.acquireSharedInterruptibly(permits);
504 sync.acquireShared(permits);
536 return sync.nonfairTryAcquireShared(permits) >= 0;
592 return sync.tryAcquireSharedNanos(permits, unit.toNanos(timeout));
619 sync.releaseShared(permits);
630 return sync.getPermits();
639 return sync.drainPermits();
654 sync.reducePermits(reduction);
663 return sync instanceof FairSync;
677 return sync.hasQueuedThreads();
690 return sync.getQueueLength();
704 return sync.getQueuedThreads();
715 return super.toString() + "[Permits = " + sync.getPermits() + "]";