Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 119 for awaiter (0.06 sec)

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

            try {
              latch.await();
            } catch (InterruptedException quittingTime) {
            }
            return TEST_STRING;
          }
        };
      }
    
      public Runnable awaiter(CountDownLatch latch) {
        return new CheckedRunnable() {
          @Override
          public void realRun() throws InterruptedException {
            await(latch);
          }
        };
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        WaiterThread waiter1 = new WaiterThread(future);
        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        WaiterThread waiter1 = new WaiterThread(future);
        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        Thread waiter =
            new Thread() {
              @Override
              public void run() {
                try {
                  service.awaitTermination(1, DAYS);
                } catch (InterruptedException e) {
                  return;
                }
              }
            };
        waiter.start();
        awaitTimedWaiting(waiter);
        service.shutdown();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        Thread waiter =
            new Thread() {
              @Override
              public void run() {
                try {
                  service.awaitTermination(1, DAYS);
                } catch (InterruptedException e) {
                  return;
                }
              }
            };
        waiter.start();
        awaitTimedWaiting(waiter);
        service.shutdown();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  6. docs/es/docs/async.md

    # Concurrencia y async / await { #concurrency-and-async-await }
    
    Detalles sobre la sintaxis `async def` para *path operation functions* y algunos antecedentes sobre el código asíncrono, la concurrencia y el paralelismo.
    
    ## ¿Con prisa? { #in-a-hurry }
    
    <abbr title="too long; didn't read"><strong>TL;DR:</strong></abbr>
    
    Si estás usando paquetes de terceros que te dicen que los llames con `await`, como:
    
    ```Python
    results = await some_library()
    ```
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 10:15:01 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Queues.java

       *
       * @param q the blocking queue to be drained
       * @param buffer where to add the transferred elements
       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
       * @return the number of elements transferred
       * @throws InterruptedException if interrupted while waiting
       * @since 33.4.0 (but since 28.0 in the JRE flavor)
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/CharStreams.java

      }
    
      /**
       * Returns a {@link Writer} that simply discards written chars.
       *
       * <p><b>Java 11+ users:</b> use {@link Writer#nullWriter()} instead. Note that the {@link
       * CharStreams} method returns a singleton writer whose {@code close} method has no effect, while
       * the {@link Writer#nullWriter()} method returns a new instance whose methods throw after the
       * instance is {@link Writer#close() closed}.
       *
       * @since 15.0
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 29 13:56:24 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/collect/QueuesTest.java

        try {
          // if waiting works, this should get stuck
          Queues.drain(q, new ArrayList<>(), 1, MAX_VALUE, NANOSECONDS);
          fail();
        } catch (InterruptedException expected) {
          // we indeed waited; a slow thread had enough time to interrupt us
        }
      }
    
      // same as above; uninterruptible version
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  10. docs/fr/docs/tutorial/background-tasks.md

        * Étant donné que se connecter à un serveur et envoyer un email a tendance à être «lent» (plusieurs secondes), vous pouvez retourner la réponse directement et envoyer la notification en arrière-plan.
    * Traiter des données :
        * Par exemple, si vous recevez un fichier qui doit passer par un traitement lent, vous pouvez retourner une réponse «Accepted» (HTTP 202) puis faire le traitement en arrière-plan.
    
    
    ## Utiliser `BackgroundTasks`
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Oct 11 17:48:49 UTC 2025
    - 5.5K bytes
    - Viewed (0)
Back to top