- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for executorService (0.14 seconds)
-
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
val maxRequests: Int = dispatcher.maxRequests dispatcher.maxRequests = 0 val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost dispatcher.maxRequestsPerHost = 0 val executorService: ExecutorService = dispatcher.executorService dispatcher.idleCallback = Runnable { TODO() } val queuedCalls: List<Call> = dispatcher.queuedCalls() val runningCalls: List<Call> = dispatcher.runningCalls()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 49.7K bytes - Click Count (0) -
okhttp/api/jvm/okhttp.api
} public final class okhttp3/Dispatcher { public final fun -deprecated_executorService ()Ljava/util/concurrent/ExecutorService; public fun <init> ()V public fun <init> (Ljava/util/concurrent/ExecutorService;)V public final fun cancelAll ()V public final fun executorService ()Ljava/util/concurrent/ExecutorService; public final fun getIdleCallback ()Ljava/lang/Runnable; public final fun getMaxRequests ()ICreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 72.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
public static <O extends @Nullable Object> ListenableFuture<O> scheduleAsync( AsyncCallable<O> callable, Duration delay, ScheduledExecutorService executorService) { return scheduleAsync(callable, toNanosSaturated(delay), NANOSECONDS, executorService); } /** * Schedules {@code callable} on the specified {@code executor}, returning a {@code Future}. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
okhttp/api/android/okhttp.api
} public final class okhttp3/Dispatcher { public final fun -deprecated_executorService ()Ljava/util/concurrent/ExecutorService; public fun <init> ()V public fun <init> (Ljava/util/concurrent/ExecutorService;)V public final fun cancelAll ()V public final fun executorService ()Ljava/util/concurrent/ExecutorService; public final fun getIdleCallback ()Ljava/lang/Runnable; public final fun getMaxRequests ()ICreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 72.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
import java.util.concurrent.CancellationException; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
import java.util.concurrent.CancellationException; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* so. * * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will * also cause future calls to the client to be rejected. * * ```java * client.dispatcher().executorService().shutdown(); * ``` * * Clear the connection pool with [evictAll()][ConnectionPool.evictAll]. Note that the connection
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 51.5K bytes - Click Count (0)