- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 78 for TimeoutException (2.19 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
import static org.junit.Assert.assertThrows; import com.google.common.util.concurrent.testing.MockFutureListener; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import junit.framework.TestCase; /** * Unit tests for any listenable future that chains other listenable futures. Unit tests need only
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingFuture.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link Future} which forwards all its method calls to another future. Subclasses should
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Mar 04 12:28:17 GMT 2022 - 3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* @param timeout the maximum time to wait * @param unit the time unit of the timeout argument * @throws TimeoutException if not all of the services have stopped within the deadline */ @SuppressWarnings("GoodTime") // should accept a java.time.Duration public void awaitStopped(long timeout, TimeUnit unit) throws TimeoutException { state.awaitStopped(timeout, unit); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
}; } @Override protected String serviceName() { return "Foo"; } }; TimeoutException e = assertThrows( TimeoutException.class, () -> service.startAsync().awaitRunning(1, TimeUnit.MILLISECONDS)); assertThat(e) .hasMessageThat()
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 7.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return true; } /** * Blocks until the task is complete or the timeout expires. Throws a {@link TimeoutException} * if the timer expires, otherwise behaves like {@link #get()}. */ V get(long nanos) throws TimeoutException, CancellationException, ExecutionException, InterruptedException { // Attempt to acquire the shared lock with a timeout.
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return true; } /** * Blocks until the task is complete or the timeout expires. Throws a {@link TimeoutException} * if the timer expires, otherwise behaves like {@link #get()}. */ V get(long nanos) throws TimeoutException, CancellationException, ExecutionException, InterruptedException { // Attempt to acquire the shared lock with a timeout.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
import java.util.concurrent.Future; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import junit.framework.TestCase; /** * Test for {@link WrappingScheduledExecutorService} * * @author Luke Sandberg */ public class WrappingScheduledExecutorServiceTest extends TestCase {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 7.6K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/SingleThreadAbstractFutureBenchmark.java
import java.util.ArrayList; import java.util.List; import java.util.concurrent.CancellationException; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; /** A benchmark that times how long it takes to add a given number of */ @VmOptions({"-Xms8g", "-Xmx8g"}) public class SingleThreadAbstractFutureBenchmark { @Param Impl impl;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jul 16 17:22:27 GMT 2019 - 3.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeoutException; import junit.framework.TestCase; /** * Unit test for {@link SimpleTimeLimiter}. * * @author kevinb * @author Jens Nyman */ public class SimpleTimeLimiterTest extends TestCase {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
* * @throws TimeoutException if this thread does not accept the request within a reasonable amount * of time */ private void sendRequest(String methodName, Object... arguments) throws Exception { if (!requestQueue.offer( new Request(methodName, arguments), TIMEOUT_MILLIS, TimeUnit.MILLISECONDS)) { throw new TimeoutException(); } } /**
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 10.9K bytes - Viewed (0)