Searched refs:availablePlaces (Results 1 - 2 of 2) sorted by relevance

/forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueue.java35 private final ResizableSemaphore availablePlaces; field in class:ResizableLinkedBlockingQueue
44 availablePlaces = new ResizableSemaphore(queueSize, true);
60 availablePlaces = new ResizableSemaphore(queueSize, true);
74 availablePlaces = new ResizableSemaphore(initialCapacity, true);
93 availablePlaces.reducePermits(difference);
96 availablePlaces.increasePermits(difference);
119 if (availablePlaces.tryAcquire()) {
124 //If the queue.offer(e) fails, the availablePlaces.tryAcquire() will still have occurred, so we'll have
126 availablePlaces.release();
141 if (availablePlaces
[all...]
/forgerock/openam/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueue.java35 private final ResizableSemaphore availablePlaces; field in class:ResizableLinkedBlockingQueue
44 availablePlaces = new ResizableSemaphore(queueSize, true);
60 availablePlaces = new ResizableSemaphore(queueSize, true);
74 availablePlaces = new ResizableSemaphore(initialCapacity, true);
93 availablePlaces.reducePermits(difference);
96 availablePlaces.increasePermits(difference);
119 if (availablePlaces.tryAcquire()) {
124 //If the queue.offer(e) fails, the availablePlaces.tryAcquire() will still have occurred, so we'll have
126 availablePlaces.release();
141 if (availablePlaces
[all...]

Completed in 67 milliseconds