Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 52 for threadPool (0.17 sec)

  1. docs/pt/docs/async.md

    ### Funções de operação de rota
    
    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 (ela poderia bloquear o servidor).
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  2. tensorflow/compiler/jit/xla_device_context.cc

        std::vector<std::shared_ptr<se::Stream>> device_to_device_streams,
        xla::LocalClient* client,
        XlaShapeLayoutHelpers::ShapeDeterminationFns shape_determination_fns,
        thread::ThreadPool* thread_pool)
        : stream_(std::move(compute_stream)),
          host_to_device_stream_(std::move(host_to_device_stream)),
          device_to_host_stream_(std::move(device_to_host_stream)),
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 16 00:36:08 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. tensorflow/compiler/jit/kernels/xla_ops.cc

    // Get-or-create thread pool for a given collective.
    static thread::ThreadPool* GetOrCreateThreadPoolForCollective(
        const XlaCompilationResult::CollectiveInfo& collective_info) {
      static absl::Mutex m(absl::kConstInit);
      static auto& thread_pool_cache ABSL_GUARDED_BY(m) =
          *new absl::node_hash_map<XlaCompilationResult::CollectiveInfo,
                                   thread::ThreadPool>();
      absl::MutexLock l(&m);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 17 22:46:36 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

            }
            throw new SearchEngineClientException("client is not HttpClient.");
        }
    
        //
        // Fesen Client
        //
    
        @Override
        public ThreadPool threadPool() {
            return client.threadPool();
        }
    
        @Override
        public AdminClient admin() {
            return client.admin();
        }
    
        @Override
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 84.1K bytes
    - Viewed (0)
  5. docs/de/docs/tutorial/request-files.md

    ```Python
    contents = myfile.file.read()
    ```
    
    !!! note "Technische Details zu `async`"
        Wenn Sie die `async`-Methoden verwenden, führt **FastAPI** die Datei-Methoden in einem <abbr title="Mehrere unabhängige Kindprozesse">Threadpool</abbr> aus und erwartet sie.
    
    !!! note "Technische Details zu Starlette"
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Mar 30 17:58:08 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. 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"
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Wed Mar 13 19:02:19 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. tensorflow/compiler/jit/xla_device.h

      std::unique_ptr<DeviceBase::AcceleratorDeviceInfo> accelerator_device_info_
          TF_GUARDED_BY(mu_);
    
      // Thread pool used for running closures
      std::unique_ptr<thread::ThreadPool> thread_pool_;
    
      // True if the device allows XlaDevice::Sync to be called on completion
      // regardless of status.
      bool sync_on_completion_ TF_GUARDED_BY(mu_) = true;
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Feb 21 09:53:30 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. tensorflow/compiler/jit/xla_device.cc

      VLOG(1) << "XlaDevice options: use_multiple_streams: "
              << options.use_multiple_streams << " use_global_compute_stream: "
              << options.use_global_compute_stream;
      thread_pool_.reset(new thread::ThreadPool(session_options.env, "xla_device",
                                                /*num_threads=*/1));
    
      // We have multiple device to device streams to allow for some concurrency
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon May 20 21:05:42 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

     *
     * <pre>{@code
     * ListenableFuture<Boolean> adminIsLoggedIn =
     *     FluentFuture.from(usersDatabase.getAdminUser())
     *         .transform(User::getId, directExecutor())
     *         .transform(ActivityService::isLoggedIn, threadPool)
     *         .catching(RpcException.class, e -> false, directExecutor());
     * }</pre>
     *
     * <h3>Alternatives</h3>
     *
     * <h4>Frameworks</h4>
     *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 11 19:08:44 UTC 2023
    - 18.7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/FluentFuture.java

     *
     * <pre>{@code
     * ListenableFuture<Boolean> adminIsLoggedIn =
     *     FluentFuture.from(usersDatabase.getAdminUser())
     *         .transform(User::getId, directExecutor())
     *         .transform(ActivityService::isLoggedIn, threadPool)
     *         .catching(RpcException.class, e -> false, directExecutor());
     * }</pre>
     *
     * <h3>Alternatives</h3>
     *
     * <h4>Frameworks</h4>
     *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 11 19:08:44 UTC 2023
    - 19.6K bytes
    - Viewed (0)
Back to top