- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 758 for Concurrent (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.util.concurrent.Futures.getDone; import static com.google.common.util.concurrent.MoreExecutors.rejectionPropagatingExecutor; import static com.google.common.util.concurrent.Platform.restoreInterruptIfIsInterruptedException;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestsForQueuesInJavaUtil.java
import java.util.LinkedList; import java.util.PriorityQueue; import java.util.Queue; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.PriorityBlockingQueue; import junit.framework.Test; import junit.framework.TestSuite; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 12 16:28:01 GMT 2025 - 7.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/ReflectionFreeAssertThrows.java
import java.util.ConcurrentModificationException; import java.util.NoSuchElementException; import java.util.concurrent.CancellationException; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeoutException; import junit.framework.AssertionFailedError; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** Replacements for JUnit's {@code assertThrows} that work under GWT/J2CL. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
* method equivalent to {@link java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. If * the {@link #callAndAssertWaits} method is ever called in a test, the lock-like object must have a * method equivalent to {@link * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 11.4K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
* the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtIncompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.CheckReturnValue; import java.util.concurrent.AbstractExecutorService; import java.util.concurrent.Callable; import java.util.concurrent.RunnableFuture; import org.jspecify.annotations.Nullable; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 12 17:47:46 GMT 2025 - 3K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
import assertk.assertions.isCloseTo import assertk.assertions.isFalse import assertk.assertions.isInstanceOf import assertk.assertions.matchesPredicate import java.util.Deque import java.util.concurrent.ConcurrentLinkedDeque import java.util.concurrent.TimeUnit import okhttp3.ConnectionEvent.NoNewExchanges import okhttp3.internal.connection.ConnectionListener import okhttp3.internal.connection.RealConnection import okio.IOException
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri May 30 21:28:20 GMT 2025 - 5.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.Futures.getUnchecked; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 4.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.Futures.getUnchecked; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.CHECKED_EXCEPTION; import static com.google.common.util.concurrent.FuturesGetCheckedInputs.ERROR;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 4.6K bytes - Click Count (0) -
guava-gwt/test/com/google/common/collect/testing/Testing.gwt.xml
util.concurrent tests under Guava. The problem is that GWT responds poorly to two .gwt.xml files in the same Java package; see https://groups.google.com/g/google-web-toolkit-contributors/c/CqYH59Dt_rQ/m/uVGW1QdUsXUJ for details. The summary is that it ignores one file in favor of the other. util.concurrent, like nearly all our packages, has two .gwt.xml files: oneCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 19 16:02:36 GMT 2024 - 1.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FakeTimeLimiterTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static org.junit.Assert.assertThrows; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 4.1K bytes - Click Count (0)