Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 93 for executorService (0.16 sec)

  1. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public abstract class ForwardingExecutorService extends ForwardingObject
        implements ExecutorService {
      /** Constructor for use by subclasses. */
      protected ForwardingExecutorService() {}
    
      @Override
      protected abstract ExecutorService delegate();
    
      @CheckReturnValue
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

    package org.codelibs.fess.crawler.interval.impl;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    
    import org.codelibs.fess.crawler.entity.UrlQueue;
    import org.codelibs.fess.crawler.entity.UrlQueueImpl;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java

    import java.io.File;
    import java.io.PrintWriter;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    import org.apache.maven.jline.JLineMessageBuilderFactory;
    import org.eclipse.aether.DefaultRepositorySystemSession;
    import org.eclipse.aether.transfer.TransferCancelledException;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        @Override
        protected final void doStart() {
          executorService =
              MoreExecutors.renamingDecorator(executor(), () -> serviceName() + " " + state());
          executorService.execute(
              () -> {
                lock.lock();
                try {
                  startUp();
                  /*
                   * requireNonNull is safe because executorService is never cleared after the
                   * assignment above.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  5. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

    import java.io.File;
    import java.io.IOException;
    import java.util.Collections;
    import java.util.LinkedHashSet;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.atomic.AtomicInteger;
    import okhttp3.Cache;
    import okhttp3.HttpUrl;
    import okhttp3.MediaType;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.ExecutorService;
    
    /**
     * Tests for {@link ClosingFuture} that exercise {@link
     * ClosingFuture#finishToValueAndCloser(ValueAndCloserConsumer, Executor)}.
     */
    public class ClosingFutureFinishToValueAndCloserTest extends AbstractClosingFutureTest {
      private final ExecutorService finishToValueAndCloserExecutor = newSingleThreadExecutor();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    import com.google.common.collect.Multiset;
    import com.google.common.testing.TestLogHandler;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.logging.Level;
    import java.util.logging.Logger;
    import junit.framework.TestCase;
    
    /** Tests for {@link ListenerCallQueue}. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    import com.google.common.collect.Multiset;
    import com.google.common.testing.TestLogHandler;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.logging.Level;
    import java.util.logging.Logger;
    import junit.framework.TestCase;
    
    /** Tests for {@link ListenerCallQueue}. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Used to test listenable future implementations.
     *
     * @author Sven Mawson
     */
    public class ListenableFutureTester {
    
      private final ExecutorService exec;
      private final ListenableFuture<?> future;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.util.ArrayList;
    import java.util.Random;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import junit.framework.TestCase;
    
    /**
     * Basher test for {@link AtomicLongMap}.
     *
     * @author mike nonemacher
     */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top