Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ThreadPoolExecutor (0.44 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ForwardingExecutorServiceTest.java

    import static java.util.concurrent.TimeUnit.SECONDS;
    
    import java.lang.reflect.Method;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.ThreadPoolExecutor;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Unit tests for {@link ForwardingExecutorService} */
    @NullUnmarked
    public class ForwardingExecutorServiceTest extends TestCase {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 18:45:52 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/timer/TimeoutManager.java

                }
            }
            if (nThreads < 1) {
                nThreads = 1;
            }
            final ExecutorService executorService = new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS,
                    new LinkedBlockingQueue<Runnable>(nThreads), new ThreadPoolExecutor.CallerRunsPolicy());
            try {
                while (!isInterrupted() && !stopIfLeisure()) {
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

     */
    package okhttp3
    
    import java.util.ArrayDeque
    import java.util.Deque
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.ThreadPoolExecutor
    import java.util.concurrent.TimeUnit
    import okhttp3.internal.assertLockNotHeld
    import okhttp3.internal.connection.RealCall
    import okhttp3.internal.connection.RealCall.AsyncCall
    import okhttp3.internal.okHttpName
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

    import java.util.concurrent.Delayed;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
    import java.util.concurrent.TimeUnit;
    
    /**
     * Factory methods for {@link ExecutorService} for testing.
     *
     * @author Chris Nokleberg
     * @since 14.0
     */
    @GwtIncompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

    import java.util.concurrent.Delayed;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
    import java.util.concurrent.TimeUnit;
    
    /**
     * Factory methods for {@link ExecutorService} for testing.
     *
     * @author Chris Nokleberg
     * @since 14.0
     */
    @GwtIncompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
Back to top