Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 21 for threadPool (0.06 seconds)

  1. src/main/java/org/codelibs/fess/suggest/SuggesterBuilder.java

            this.analyzer = analyzer;
            return this;
        }
    
        /**
         * Sets the thread pool.
         * @param threadPool The thread pool.
         * @return This builder instance.
         */
        public SuggesterBuilder threadPool(final ExecutorService threadPool) {
            this.threadPool = threadPool;
            return this;
        }
    
        /**
         * Sets the thread pool size.
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Mon Nov 24 03:40:05 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

        int deltaRange = 10000;
        String key = "key";
    
        AtomicLongMap<String> map = AtomicLongMap.create();
    
        ExecutorService threadPool = newFixedThreadPool(nThreads);
        ArrayList<Future<Long>> futures = new ArrayList<>();
        for (int i = 0; i < nTasks; i++) {
          futures.add(
              threadPool.submit(
                  new Callable<Long>() {
                    @Override
                    public Long call() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  3. 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)
  4. guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

        int deltaRange = 10000;
        String key = "key";
    
        AtomicLongMap<String> map = AtomicLongMap.create();
    
        ExecutorService threadPool = newFixedThreadPool(nThreads);
        ArrayList<Future<Long>> futures = new ArrayList<>();
        for (int i = 0; i < nTasks; i++) {
          futures.add(
              threadPool.submit(
                  new Callable<Long>() {
                    @Override
                    public Long call() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. build-tools-internal/src/main/resources/forbidden/es-all-signatures.txt

    @defaultMessage extend org.elasticsearch.threadpool.Scheduler.SafeScheduledThreadPoolExecutor instead which will properly bubble up Errors
    java.util.concurrent.ScheduledThreadPoolExecutor#<init>(int)
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Sep 01 15:21:26 GMT 2021
    - 3.8K bytes
    - Click Count (0)
Back to Top