Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 31 for pthreadpool (0.06 seconds)

  1. MODULE.bazel

    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Apr 02 01:32:13 GMT 2026
    - 11K bytes
    - Click Count (0)
  2. tensorflow/BUILD

        "@zlib//:__subpackages__",
        "@dlpack//:__subpackages__",
        "@arm_neon_2_x86_sse//:__subpackages__",
        "@cpuinfo//:__subpackages__",
        "@ruy//:__subpackages__",
        "@XNNPACK//:__subpackages__",
        "@pthreadpool//:__subpackages__",
        "@FXdiv//:__subpackages__",
        "@FP16//:__subpackages__",
        "@clog//:__subpackages__",
        "@flatbuffers//:__subpackages__",
        "@nccl_archive//:__subpackages__",
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Tue Mar 24 21:00:18 GMT 2026
    - 53.1K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/curl/CurlRequest.java

            }
        }
    
        /**
         * Sets the thread pool for executing the request.
         *
         * @param threadPool the thread pool
         * @return this CurlRequest instance
         */
        public CurlRequest threadPool(final ForkJoinPool threadPool) {
            this.threadPool = threadPool;
            return this;
        }
    
        /**
         * Sets the connection and read timeouts for the request.
         *
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 19.7K bytes
    - Click Count (0)
  4. fastapi/datastructures.py

            To be awaitable, compatible with async, this is run in threadpool.
            """
            return await super().seek(offset)
    
        async def close(self) -> None:
            """
            Close the file.
    
            To be awaitable, compatible with async, this is run in threadpool.
            """
            return await super().close()
    
        @classmethod
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 5.2K bytes
    - Click Count (0)
  5. 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)
  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. .teamcity/scripts/CheckBadMerge.java

     *
     * If any "bad" merge commit is found, it will print the details and exit with non-zero code.
     */
    public class CheckBadMerge {
        private static final ExecutorService THREAD_POOL = Executors.newCachedThreadPool();
    
        private static final List<String> MONITORED_PATHS = Collections.unmodifiableList(Arrays.asList(
            "subprojects/docs/src/docs/release/notes.md",
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 30 16:25:09 GMT 2026
    - 9K bytes
    - Click Count (0)
  9. 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)
  10. docs/pt/docs/async.md

    ///
    
    ### Funções de operação de rota { #path-operation-functions }
    
    Quando você declara uma *função de operação de rota* com `def` normal ao invés de `async def`, ela é rodada em uma threadpool externa que é então aguardada, ao invés de ser chamada diretamente (já que ela bloquearia o servidor).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 25.2K bytes
    - Click Count (0)
Back to Top