- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 46 for Threadpool (0.4 seconds)
-
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) -
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) -
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) -
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) -
docs/en/docs/advanced/stream-data.md
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) -
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) -
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) -
fastapi/.agents/skills/fastapi/SKILL.md
@app.get("/items/") def read_items(): data = some_blocking_library.fetch_items() return data ``` In case of doubt, or by default, use regular `def` functions, those will be run in a threadpool so they don't block the event loop. The same rules apply to dependencies. Make sure blocking code is not run inside of `async` functions. The logic will work, but will damage the performance heavily.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sun Mar 01 10:05:57 GMT 2026 - 10.1K bytes - Click Count (0) -
.bazelrc
common:mkl_threadpool --define=build_with_mkl=true --define=enable_mkl=true common:mkl_threadpool --define=tensorflow_mkldnn_contraction_kernel=0 common:mkl_threadpool --define=build_with_mkl_opensource=true common:mkl_threadpool -c opt # Config setting to build oneDNN with Compute Library for the Arm Architecture (ACL). # with Eigen threadpool support
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Sat Mar 28 04:33:01 GMT 2026 - 58.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* * {@snippet : * ListenableFuture<Boolean> adminIsLoggedIn = * FluentFuture.from(usersDatabase.getAdminUser()) * .transform(User::getId, directExecutor()) * .transform(ActivityService::isLoggedIn, threadPool) * .catching(RpcException.class, e -> false, directExecutor()); * } * * <h3>Alternatives</h3> * * <h4>Frameworks</h4> *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 19.8K bytes - Click Count (0)