Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 46 for Threadpool (0.4 seconds)

  1. src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

            ForkJoinPool pool = new ForkJoinPool(1);
            req.threadPool(pool);
    
            // ## Act ##
            // execute() should force synchronous execution but restore threadPool afterward
            try (CurlResponse response = req.execute()) {
                assertEquals(200, response.getHttpStatusCode());
            }
    
            // ## Assert ##
            // After execute(), the threadPool should be restored
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 12:00:34 GMT 2026
    - 44.1K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        ExecutorService threadPool = newFixedThreadPool(nThreads);
        CountDownLatch tasksFinished = new CountDownLatch(nTasks);
        for (int i = 0; i < nTasks; i++) {
          String s = "a" + i;
          @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
          Future<?> possiblyIgnoredError =
              threadPool.submit(
                  () -> {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 25.7K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        ExecutorService threadPool = newFixedThreadPool(nThreads);
        CountDownLatch tasksFinished = new CountDownLatch(nTasks);
        for (int i = 0; i < nTasks; i++) {
          String s = "a" + i;
          @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
          Future<?> possiblyIgnoredError =
              threadPool.submit(
                  () -> {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  4. docs/en/docs/tutorial/request-files.md

    ```Python
    contents = myfile.file.read()
    ```
    
    /// note | `async` Technical Details
    
    When you use the `async` methods, **FastAPI** runs the file methods in a threadpool and awaits for them.
    
    ///
    
    /// note | Starlette Technical Details
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 7K bytes
    - Click Count (0)
  5. docs/en/docs/advanced/stream-data.md

    ///
    
    To avoid blocking the event loop, you can simply declare the *path operation function* with regular `def` instead of `async def`, that way FastAPI will run it on a threadpool worker, to avoid blocking the main loop.
    
    {* ../../docs_src/stream_data/tutorial002_py310.py ln[30:34] hl[31] *}
    
    /// tip
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 5.4K bytes
    - Click Count (0)
  6. docs/zh-hant/docs/advanced/stream-data.md

    而且在許多情況下,讀取它們會是阻塞操作(可能阻塞事件迴圈),因為資料是從磁碟或網路讀取。
    
    /// info
    
    上面的範例其實是例外,因為 `io.BytesIO` 物件已在記憶體中,讀取不會阻塞任何東西。
    
    但在多數情況下,讀取檔案或類檔案物件會造成阻塞。
    
    ///
    
    為了避免阻塞事件迴圈,你可以將路徑操作函式宣告為一般的 `def`(而非 `async def`),這樣 FastAPI 會在 threadpool worker 上執行它,避免阻塞主事件迴圈。
    
    {* ../../docs_src/stream_data/tutorial002_py310.py ln[30:34] hl[31] *}
    
    /// tip
    
    如果你需要在 async 函式內呼叫阻塞程式碼,或在阻塞函式中呼叫 async 函式,你可以使用 [Asyncer](https://asyncer.tiangolo.com),它是 FastAPI 的姊妹函式庫。
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:33:04 GMT 2026
    - 4.9K bytes
    - Click Count (0)
  7. build-tools-internal/src/main/resources/forbidden/es-server-signatures.txt

    @defaultMessage Spawns a new thread which is solely under lucenes control use ThreadPool#relativeTimeInMillis instead
    org.apache.lucene.search.TimeLimitingCollector#getGlobalTimerThread()
    org.apache.lucene.search.TimeLimitingCollector#getGlobalCounter()
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 08 16:53:28 GMT 2021
    - 7.6K bytes
    - Click Count (0)
  8. fastapi/.agents/skills/fastapi/SKILL.md

    @app.get("/items/")
    def read_items():
        data = some_blocking_library.fetch_items()
        return data
    ```
    
    In case of doubt, or by default, use regular `def` functions, those will be run in a threadpool so they don't block the event loop.
    
    The same rules apply to dependencies.
    
    Make sure blocking code is not run inside of `async` functions. The logic will work, but will damage the performance heavily.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 01 10:05:57 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  9. .bazelrc

    common:mkl_threadpool --define=build_with_mkl=true --define=enable_mkl=true
    common:mkl_threadpool --define=tensorflow_mkldnn_contraction_kernel=0
    common:mkl_threadpool --define=build_with_mkl_opensource=true
    common:mkl_threadpool -c opt
    
    # Config setting to build oneDNN with Compute Library for the Arm Architecture (ACL).
    # with Eigen threadpool support
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Mar 28 04:33:01 GMT 2026
    - 58.9K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

     *
     * {@snippet :
     * ListenableFuture<Boolean> adminIsLoggedIn =
     *     FluentFuture.from(usersDatabase.getAdminUser())
     *         .transform(User::getId, directExecutor())
     *         .transform(ActivityService::isLoggedIn, threadPool)
     *         .catching(RpcException.class, e -> false, directExecutor());
     * }
     *
     * <h3>Alternatives</h3>
     *
     * <h4>Frameworks</h4>
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
Back to Top