Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 43 for pthreadpool (0.33 seconds)

  1. .teamcity/scripts/CheckWrapper.java

     *   java .teamcity/scripts/CheckWrapper.java < commits.txt
     *
     * Reads commit SHAs from stdin (one per line), checks wrapper per commit.
     */
    public class CheckWrapper {
        private static final ExecutorService THREAD_POOL = Executors.newCachedThreadPool();
    
        private static final Pattern ALLOWED_WRAPPER_VERSION =
            Pattern.compile("^[0-9.]+(-(rc|milestone|m)-[0-9]+)?$");
    
        // Keep the same extraction semantics as the old sed:
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Jan 20 03:53:25 GMT 2026
    - 6.4K bytes
    - Click Count (0)
  2. .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)
  3. 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)
  4. src/main/java/jcifs/SmbResourceException.java

        private static final long serialVersionUID = 1L;
    
        /**
         * Resource type that caused the error
         */
        public enum ResourceType {
            FILE_HANDLE, CONNECTION, MEMORY, DISK_SPACE, QUOTA, LOCK, BUFFER, THREAD_POOL
        }
    
        private final ResourceType resourceType;
        private final long availableResources;
        private final long requestedResources;
    
        /**
         * Creates a resource exception
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 5.6K 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. tensorflow/c/c_api_experimental.cc

      // TODO(b/113217601): This is needed for EagerContext::runner_ to use a
      // threadpool, so that we avoid the possibility of running the runner_ in the
      // threadpool of GPU event mgr, as that can trigger more callbacks to be
      // scheduled on that same threadpool, causing a deadlock in cases where the
      // caller of event_mgr->ThenExecute() blocks on the completion of the callback
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Oct 04 05:55:32 GMT 2025
    - 29.4K bytes
    - Click Count (0)
  7. 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)
  8. docs/fr/docs/async.md

    ///
    
    ### Fonctions de chemin d'accès { #path-operation-functions }
    
    Quand vous déclarez une *fonction de chemin d'accès* avec un `def` normal et non `async def`, elle est exécutée dans un groupe de threads (threadpool) externe qui est ensuite attendu, plutôt que d'être appelée directement (car cela bloquerait le serveur).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 27.3K bytes
    - Click Count (0)
  9. 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)
  10. docs/ru/docs/advanced/stream-data.md

    ///
    
    Чтобы не блокировать цикл событий, вы можете просто объявить *функцию-обработчик пути* обычной `def` вместо `async def`. Тогда FastAPI выполнит её в воркере из пула потоков (threadpool), чтобы не блокировать основной цикл.
    
    {* ../../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 19 17:56:20 GMT 2026
    - 8.9K bytes
    - Click Count (0)
Back to Top