- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for ConcurrentLinkedQueue (0.19 seconds)
-
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, inCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 18K bytes - Click Count (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, inCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 18.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/LocalCacheMapComputeTest.java
import static org.junit.Assert.assertThrows; import com.google.common.util.concurrent.UncheckedExecutionException; import java.util.ArrayList; import java.util.List; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ExecutionException; import java.util.function.IntConsumer; import java.util.stream.IntStream; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 30 22:03:28 GMT 2025 - 7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.connection import java.net.Socket import java.util.concurrent.ConcurrentLinkedQueue import java.util.concurrent.TimeUnit import okhttp3.Address import okhttp3.ConnectionPool import okhttp3.Route import okhttp3.internal.closeQuietly import okhttp3.internal.concurrent.Task
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 11.1K bytes - Click Count (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>() {
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-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)