- Sort Score
- Result 10 results
- Languages All
Results 11 - 15 of 15 for unqueued (0.14 sec)
-
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
implements BlockingQueue<E> { // Based on revision 1.58 of ArrayBlockingQueue by Doug Lea, from // http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/ /** The queued items */ final E[] items; /** items index for next take, poll or remove */ int takeIndex; /** items index for next put, offer, or add. */ int putIndex; /** Number of items in the queue */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
implements BlockingQueue<E> { // Based on revision 1.58 of ArrayBlockingQueue by Doug Lea, from // http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/ /** The queued items */ final E[] items; /** items index for next take, poll or remove */ int takeIndex; /** items index for next put, offer, or add. */ int putIndex; /** Number of items in the queue */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterables.java
* Queue#isEmpty} and {@link Queue#remove()}, since {@link Queue}'s iteration order is undefined. * Calling {@link Iterator#hasNext()} on a generated iterator from the returned iterable may cause * an item to be immediately dequeued for return on a subsequent call to {@link Iterator#next()}. * * <p>Whether the input {@code iterable} is a {@link Queue} or not, the returned {@code Iterable} * is not thread-safe. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 24 19:38:27 UTC 2024 - 42.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
/** * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run * or queued. */ @CheckForNull ExecutionSequencer sequencer; /** * Executor the task was set to run on. Set to null when the task has been queued, run, or * cancelled. */ @CheckForNull Executor delegate; /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
protected void finalize() { finalizerRan.countDown(); } }); await(finalizerRan); awaitClear(ref); // Hope to catch some stragglers queued up behind our finalizable object System.runFinalization(); } private static RuntimeException formatRuntimeException(String format, Object... args) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.6K bytes - Viewed (0)