Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 236 for executor_ (0.07 sec)

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

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertWithMessage;
    
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import junit.framework.TestCase;
    
    /** Test for {@link ListenableFuture}. */
    public class ListenableFutureTest extends TestCase {
      public void testNoNewApis() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jun 15 19:48:16 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  2. docs/fr/docs/deployment/manually.md

    # Exécuter un serveur manuellement - Uvicorn
    
    La principale chose dont vous avez besoin pour exécuter une application **FastAPI** sur une machine serveur distante est un programme serveur ASGI tel que **Uvicorn**.
    
    Il existe 3 principales alternatives :
    
    * <a href="https://www.uvicorn.org/" class="external-link" target="_blank">Uvicorn</a> : un serveur ASGI haute performance.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    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}. */
    public class ListenerCallQueueTest extends TestCase {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

    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}. */
    public class ListenerCallQueueTest extends TestCase {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

    import java.util.concurrent.CancellationException;
    import java.util.concurrent.CountDownLatch;
    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 {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. docs/fr/README.md

    ## Vue d'ensemble
    
    Fess est un serveur de recherche très puissant et facilement déployable pour les entreprises. Vous pouvez rapidement installer et exécuter Fess sur toute plateforme où vous pouvez exécuter l'environnement d'exécution Java. Fess est fourni sous la licence [Apache License 2.0](LICENSE).
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 07:19:47 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.base.Preconditions;
    import java.util.concurrent.Executor;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A {@link ListenableFuture} which forwards all its method calls to another future. Subclasses
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Mar 04 12:23:41 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

    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
     */
    @J2ktIncompatible // threads
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      public static boolean awaitTerminationUninterruptibly(
          ExecutorService executor, Duration timeout) {
        return awaitTerminationUninterruptibly(executor, toNanosSaturated(timeout), NANOSECONDS);
      }
    
      /**
       * Invokes {@code executor.}{@link ExecutorService#awaitTermination(long, TimeUnit)
       * awaitTermination(long, TimeUnit)} uninterruptibly.
       *
       * @since 30.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

    import okhttp3.internal.okHttpName
    import okhttp3.internal.threadFactory
    
    /**
     * Policy on when async requests are executed.
     *
     * Each dispatcher uses an [ExecutorService] to run calls internally. If you supply your own
     * executor, it should be able to run [the configured maximum][maxRequests] number of calls
     * concurrently.
     */
    class Dispatcher() {
      internal val lock: ReentrantLock = ReentrantLock()
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top