Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 236 for executor_ (0.06 sec)

  1. docs/pt/docs/advanced/async-tests.md

    O `TestClient` faz algumas mágicas para invocar a aplicação FastAPI assíncrona em suas funções `def` normais, utilizando o pytest padrão. Porém a mágica não acontece mais quando nós estamos utilizando dentro de funções assíncronas. Ao executar os nossos testes de forma assíncrona, nós não podemos mais utilizar o `TestClient` dentro das nossas funções de teste.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. docs/fr/docs/tutorial/background-tasks.md

    {* ../../docs_src/background_tasks/tutorial001.py hl[1,13] *}
    
    **FastAPI** créera l'objet de type `BackgroundTasks` pour vous et le passera comme paramètre.
    
    ## Créer une fonction de tâche
    
    Une fonction à exécuter comme tâche d'arrière-plan est juste une fonction standard qui peut recevoir des paramètres.
    
    Elle peut être une fonction asynchrone (`async def`) ou une fonction normale (`def`), **FastAPI** saura la gérer correctement.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:29:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

            new Service() {
              final NoOpService delegate = new NoOpService();
    
              @Override
              public final void addListener(Listener listener, Executor executor) {
                service1.startAsync();
                delegate.addListener(listener, executor);
              }
    
              // Delegates from here on down
              @Override
              public final Service startAsync() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ConcurrentNavigableMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    import java.util.concurrent.LinkedBlockingDeque;
    import java.util.concurrent.ScheduledThreadPoolExecutor;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.ThreadPoolExecutor;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  5. docs/fr/docs/contributing.md

    De cette façon, vous n'avez pas à "installer" votre version locale pour pouvoir tester chaque changement.
    
    ### Formatage
    
    Il existe un script que vous pouvez exécuter qui formatera et nettoiera tout votre code :
    
    <div class="termy">
    
    ```console
    $ bash scripts/format.sh
    ```
    
    </div>
    
    Il effectuera également un tri automatique de touts vos imports.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. docs/pt/docs/tutorial/sql-databases.md

    ### Deletar um Hero
    
    Também podemos **deletar** um `Hero`.
    
    {* ../../docs_src/sql_databases/tutorial001_an_py310.py ln[66:73] hl[71] *}
    
    ### Executar o App
    
    Você pode executar o app:
    
    <div class="termy">
    
    ```console
    $ fastapi dev main.py
    
    <span style="color: green;">INFO</span>:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:25:29 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

          get() = originalRequest
    
        val call: RealCall
          get() = this@RealCall
    
        /**
         * Attempt to enqueue this async call on [executorService]. This will attempt to clean up
         * if the executor has been shut down by reporting the call as failed.
         */
        fun executeOn(executorService: ExecutorService) {
          client.dispatcher.assertThreadDoesntHoldLock()
    
          var success = false
          try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        server.enqueue(MockResponse(body = "A"))
        server.enqueue(MockResponse(body = "A"))
        val executor = Executors.newCachedThreadPool(threadFactory("HttpOverHttp2Test"))
        val countDownLatch = CountDownLatch(2)
        executor.execute(AsyncRequest("/r1", countDownLatch))
        executor.execute(AsyncRequest("/r2", countDownLatch))
        countDownLatch.await()
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

            .connectionPool(
              buildConnectionPool(
                connectionListener = connectionListener,
                taskRunner = taskRunner,
              ),
            )
            .dispatcher(Dispatcher(backend.executor))
            .taskRunnerInternal(taskRunner)
        } else {
          OkHttpClient.Builder()
            .connectionPool(ConnectionPool(connectionListener = connectionListener))
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/DuplexTest.kt

    import java.io.IOException
    import java.net.HttpURLConnection
    import java.net.ProtocolException
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.Executors
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
Back to top