- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 70 for queue (0.13 sec)
-
guava-tests/benchmark/com/google/common/collect/MinMaxPriorityQueueBenchmark.java
@Param({"100", "10000"}) private int size; @Param private HeapType heap; private Queue<Integer> queue; private final Random random = new Random(); @BeforeExperiment void setUp() { queue = heap.create(comparator.get()); for (int i = 0; i < size; i++) { queue.add(random.nextInt()); } } @Benchmark void pollAndAdd(int reps) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
final L listener; final Executor executor; @GuardedBy("this") final Queue<ListenerCallQueue.Event<L>> waitQueue = Queues.newArrayDeque(); @GuardedBy("this") final Queue<Object> labelQueue = Queues.newArrayDeque(); @GuardedBy("this") boolean isThreadScheduled; PerListenerQueue(L listener, Executor executor) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBenchmark.java
queue = (BlockingQueue<String>) constructor.newInstance(capacity); strings = new String[capacity]; for (int i = 0; i < capacity; i++) { strings[i] = String.valueOf(Math.random()); } } @Benchmark void addsAndRemoves(int reps) { int capacity = this.capacity; BlockingQueue<String> queue = this.queue; String[] strings = this.strings;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestQueueGenerator.java
import java.util.Queue; import org.checkerframework.checker.nullness.qual.Nullable; /** * Creates queues, containing sample elements, to be tested. * * @author Jared Levy */ @GwtCompatible @ElementTypesAreNonnullByDefault public interface TestQueueGenerator<E extends @Nullable Object> extends TestCollectionGenerator<E> { @Override Queue<E> create(Object... elements);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 1.1K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/collect/testing/OpenJdk6QueueTests.java
import java.lang.reflect.Method; import java.util.Arrays; import java.util.Collection; import java.util.List; import java.util.Queue; import junit.framework.Test; /** * Tests the {@link Queue} implementations of {@link java.util}, suppressing tests that trip known * OpenJDK 6 bugs. * * @author Kevin Bourrillion */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 1.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineReader.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.IOException; import java.io.Reader; import java.nio.CharBuffer; import java.util.ArrayDeque; import java.util.Queue; import javax.annotation.CheckForNull; /** * A class for reading lines of text. Provides the same functionality as {@link * java.io.BufferedReader#readLine()} but for all {@link Readable} objects, not just instances of
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 3.1K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueElementTester.java
import com.google.common.collect.testing.features.CollectionSize; import java.util.NoSuchElementException; import org.junit.Ignore; /** * A generic JUnit test which tests {@code element()} operations on a queue. Can't be invoked * directly; please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}. * * @author Jared Levy */ @GwtCompatible
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jan 09 20:10:38 GMT 2018 - 2.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/QueueOfferTester.java
import com.google.common.annotations.GwtCompatible; import com.google.common.collect.testing.features.CollectionFeature; import org.junit.Ignore; /** * A generic JUnit test which tests offer operations on a queue. Can't be invoked directly; please * see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}. * * @author Jared Levy */ @GwtCompatible
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java
import com.google.common.collect.testing.features.CollectionSize; import java.util.NoSuchElementException; import org.junit.Ignore; /** * A generic JUnit test which tests {@code remove()} operations on a queue. Can't be invoked * directly; please see {@link com.google.common.collect.testing.CollectionTestSuiteBuilder}. * * @author Jared Levy */ @GwtCompatible
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 2.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/TestingRemovalListeners.java
static <K, V> CountingRemovalListener<K, V> countingRemovalListener() { return new CountingRemovalListener<>(); } /** {@link RemovalListener} that adds all {@link RemovalNotification} objects to a queue. */ @GwtIncompatible // ConcurrentLinkedQueue static class QueuingRemovalListener<K, V> extends ConcurrentLinkedQueue<RemovalNotification<K, V>> implements RemovalListener<K, V> { @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3K bytes - Viewed (0)