Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for executorService (0.14 seconds)

  1. 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)
  2. 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 ()I
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 72.3K bytes
    - Click Count (0)
  3. 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)
  4. 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 ()I
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 72.3K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
Back to Top