- Sort Score
- Num 10 results
- Language All
Results 11 - 14 of 14 for ConcurrentLinkedQueue (0.24 seconds)
-
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>() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 10 23:13:45 GMT 2025 - 17.2K bytes - Click Count (0) -
docs/contribute/concurrency.md
#### Per-Connection Locks Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (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>() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 10 23:13:45 GMT 2025 - 17.2K bytes - Click Count (0) -
guava/src/com/google/common/cache/LocalCache.java
import java.util.LinkedHashSet; import java.util.Map; import java.util.NoSuchElementException; import java.util.Queue; import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReferenceArray;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 19:35:11 GMT 2025 - 148.9K bytes - Click Count (0)