- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 82 for enqueue (1.15 sec)
-
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} } } /** Invokes {@code queue.}{@link BlockingQueue#take() take()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency public static <E> E takeUninterruptibly(BlockingQueue<E> queue) { boolean interrupted = false; try { while (true) { try { return queue.take(); } catch (InterruptedException e) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/IterablesTest.java
private final Queue<T> queue; UnIterableQueue(Queue<T> queue) { this.queue = queue; } @Override public Iterator<T> iterator() { throw new UnsupportedOperationException(); } @Override protected Queue<T> delegate() { return queue; } } public void testIndexOf_empty() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 47.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) { super(referent, queue); this.entry = entry; } @Override public E getEntry() { return entry; } @Override public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) { return new WeakValueReferenceImpl<>(queue, get(), entry); } } /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 91.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/QueueTestSuiteBuilder.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.ArrayList; import java.util.List; /** * Creates, based on your criteria, a JUnit test suite that exhaustively tests a queue * implementation. * * @author Jared Levy */ @GwtIncompatible public final class QueueTestSuiteBuilder<E> extends AbstractCollectionTestSuiteBuilder<QueueTestSuiteBuilder<E>, E> {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Feb 26 19:46:10 GMT 2024 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* <p>After execution begins on a thread from the {@code delegate} {@link Executor}, tasks are * polled and executed from a task queue until there are no more tasks. The thread will not be * released until there are no more tasks to run. * * <p>If a task is submitted while a thread is executing tasks from the task queue, the thread * will not be released until that submitted task is also complete. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
new LinkedBlockingDeque<Object>(10), new PriorityBlockingQueue<Object>(10, Ordering.arbitrary())); } /* * We need to perform operations in a thread pool, even for simple cases, because the queue might * be a SynchronousQueue. */ private ExecutorService threadPool; @Override public void setUp() { threadPool = newCachedThreadPool(); } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteStreams.java
import java.nio.ByteBuffer; import java.nio.channels.FileChannel; import java.nio.channels.ReadableByteChannel; import java.nio.channels.WritableByteChannel; import java.util.ArrayDeque; import java.util.Arrays; import java.util.Queue; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Provides utility methods for working with byte arrays and I/O streams. * * @author Chris Nokleberg
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 17 18:59:58 GMT 2024 - 29.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/BenchmarkHelpers.java
import com.google.common.base.Equivalence; import java.util.Collection; import java.util.Collections; import java.util.HashSet; import java.util.LinkedHashSet; import java.util.Map; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri Mar 04 04:06:35 GMT 2022 - 12.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java
* garbage-collected after that. */ public static class MyFinalizableWeakReference extends FinalizableWeakReference<Object> { public MyFinalizableWeakReference(Object x, FinalizableReferenceQueue queue) { super(x, queue); } @Override public void finalizeReferent() {} } private static class PermissivePolicy extends Policy { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 13.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/BenchmarkHelpers.java
import com.google.common.base.Equivalence; import java.util.Collection; import java.util.Collections; import java.util.HashSet; import java.util.LinkedHashSet; import java.util.Map; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Mar 04 04:06:35 GMT 2022 - 12.3K bytes - Viewed (0)