- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for RejectedExecutionException (0.33 sec)
-
android/guava/src/com/google/common/util/concurrent/ListeningExecutorService.java
* @return a {@code ListenableFuture} representing pending completion of the task * @throws RejectedExecutionException {@inheritDoc} */ @Override <T extends @Nullable Object> ListenableFuture<T> submit(Callable<T> task); /** * @return a {@code ListenableFuture} representing pending completion of the task * @throws RejectedExecutionException {@inheritDoc} */ @Override ListenableFuture<?> submit(Runnable task);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Sun Jun 20 10:45:35 GMT 2021 - 4.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
throw new RejectedExecutionException(); } r.run(); } }); Runnable task = new Runnable() { @Override public void run() { numCalls.incrementAndGet(); } }; assertThrows(RejectedExecutionException.class, () -> executor.execute(task));
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
throw new RejectedExecutionException(); } r.run(); } }); Runnable task = new Runnable() { @Override public void run() { numCalls.incrementAndGet(); } }; assertThrows(RejectedExecutionException.class, () -> executor.execute(task));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* limitations under the License. */ package okhttp3.internal.concurrent import java.util.concurrent.CountDownLatch import java.util.concurrent.RejectedExecutionException import java.util.concurrent.locks.ReentrantLock import kotlin.concurrent.withLock import okhttp3.internal.assertNotHeld import okhttp3.internal.okHttpName /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
import com.google.j2objc.annotations.RetainedWith; import java.util.ArrayDeque; import java.util.Deque; import java.util.concurrent.Executor; import java.util.concurrent.RejectedExecutionException; import java.util.logging.Level; import javax.annotation.CheckForNull; /** * Executor ensuring that all Runnables submitted are executed in order, using the provided
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
* limitations under the License. */ package okhttp3 import assertk.assertThat import assertk.assertions.containsExactly import java.util.concurrent.AbstractExecutorService import java.util.concurrent.RejectedExecutionException import java.util.concurrent.TimeUnit import okhttp3.internal.connection.RealCall import okhttp3.internal.finishedAccessor internal class RecordingExecutor( private val dispatcherTest: DispatcherTest,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ThreadFactory;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
/** * Checks if the executor has been shut down and increments the running task count. * * @throws RejectedExecutionException if the executor has been previously shutdown */ private void startTask() { synchronized (lock) { if (shutdown) { throw new RejectedExecutionException("Executor already shutdown"); } runningTasks++; } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
*/ package com.google.common.util.concurrent; import com.google.errorprone.annotations.DoNotMock; import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.RejectedExecutionException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
import java.util.concurrent.Callable; import java.util.concurrent.CancellationException; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.RejectedExecutionException; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** Aggregate future that computes its value by calling a callable. */ @GwtCompatible
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0)