- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ConcurrentLinkedQueue (0.23 sec)
-
guava/src/com/google/common/collect/Queues.java
return deque; } // ConcurrentLinkedQueue /** Creates an empty {@code ConcurrentLinkedQueue}. */ @J2ktIncompatible @GwtIncompatible // ConcurrentLinkedQueue public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue() { return new ConcurrentLinkedQueue<>(); } /** * Creates a {@code ConcurrentLinkedQueue} containing the elements of the specified iterable, in
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 14:11:14 UTC 2024 - 18.2K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
} return queueHolder; } protected static class QueueHolder { protected Queue<OpenSearchUrlQueue> waitingQueue = new ConcurrentLinkedQueue<>(); protected Queue<OpenSearchUrlQueue> crawlingQueue = new ConcurrentLinkedQueue<>(); } public void setPollingFetchSize(final int pollingFetchSize) { this.pollingFetchSize = pollingFetchSize; }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 13.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
return deque; } // ConcurrentLinkedQueue /** Creates an empty {@code ConcurrentLinkedQueue}. */ @J2ktIncompatible @GwtIncompatible // ConcurrentLinkedQueue public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue() { return new ConcurrentLinkedQueue<>(); } /** * Creates a {@code ConcurrentLinkedQueue} containing the elements of the specified iterable, in
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 26 14:11:14 UTC 2024 - 18.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java
new TestStringQueueGenerator() { @Override public Queue<String> create(String[] elements) { return new ConcurrentLinkedQueue<>(MinimalCollection.of(elements)); } }) .named("ConcurrentLinkedQueue") .withFeatures( CollectionFeature.GENERAL_PURPOSE, CollectionFeature.KNOWN_ORDER, CollectionSize.ANY)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/Helpers.java
* the size method */ public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) { // It would be nice to be able to return a real concurrent // collection like ConcurrentLinkedQueue, so that e.g. concurrent // iteration would work, but that would not be GWT-compatible. // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt. return new AbstractList<T>() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 17.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/Helpers.java
* the size method */ public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) { // It would be nice to be able to return a real concurrent // collection like ConcurrentLinkedQueue, so that e.g. concurrent // iteration would work, but that would not be GWT-compatible. // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt. return new AbstractList<T>() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 17.5K bytes - Viewed (0)