Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 51 for Threadpool (0.05 seconds)

  1. docs/en/docs/async.md

    ///
    
    ### Path operation functions { #path-operation-functions }
    
    When you declare a *path operation function* with normal `def` instead of `async def`, it is run in an external threadpool that is then awaited, instead of being called directly (as it would block the server).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 23.4K bytes
    - Click Count (0)
  2. guava-tests/benchmark/com/google/common/collect/ConcurrentHashMultisetBenchmark.java

      private ImmutableList<Integer> keys;
      private ExecutorService threadPool;
    
      @BeforeExperiment
      void setUp() throws Exception {
        multiset = implSupplier.get();
        ImmutableList.Builder<Integer> builder = ImmutableList.builder();
        for (int i = 0; i < size; i++) {
          builder.add(i);
        }
        keys = builder.build();
        threadPool = newFixedThreadPool(threads, new ThreadFactoryBuilder().setDaemon(true).build());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/curl/CurlRequestTest.java

            ForkJoinPool pool1 = new ForkJoinPool(2);
            ForkJoinPool pool2 = new ForkJoinPool(4);
    
            // Multiple threadPool calls should work
            request.threadPool(pool1);
            request.threadPool(pool2);
    
            assertNotNull(request);
        }
    
        @Test
        public void testOnConnectWithNull() {
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 24.7K bytes
    - Click Count (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            connected = false;
        }
    
        /**
         * Gets the thread pool from the underlying client.
         *
         * @return The thread pool.
         */
        @Override
        public ThreadPool threadPool() {
            return client.threadPool();
        }
    
        /**
         * Gets the admin client for cluster and index operations.
         *
         * @return The admin client.
         */
        @Override
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Nov 23 02:01:26 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. build-tools-internal/src/main/resources/checkstyle.xml

            <property name="ignoreSetter" value="true" />
            <property name="setterCanReturnItsClass" value="true"/>
            <property name="ignoreFormat" value="^(threadPool)$"/>
        </module>
        -->
    
        <!-- We don't use Java's builtin serialization and we suppress all warning
          about it. The flip side of that coin is that we shouldn't _try_ to use
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Mon Sep 13 12:48:46 GMT 2021
    - 6K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top