- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 51 for Threadpool (0.05 seconds)
-
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) -
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) -
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) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
connected = false; } /** * Gets the thread pool from the underlying client. * * @return The thread pool. */ @Override public ThreadPool threadPool() { return client.threadPool(); } /** * Gets the admin client for cluster and index operations. * * @return The admin client. */ @OverrideCreated: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Nov 23 02:01:26 GMT 2025 - 26.2K bytes - Click Count (0) -
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) -
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) -
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/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)