- Sort Score
- Num 10 results
- Language All
Results 1 - 4 of 4 for ForkJoinPool (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/org/codelibs/curl/CurlRequestTest.java
} @Test public void testMultipleThreadPoolCalls() { CurlRequest request = new CurlRequest(Method.GET, "https://example.com"); ForkJoinPool pool1 = new ForkJoinPool(2); ForkJoinPool pool2 = new ForkJoinPool(4); // Multiple threadPool calls should work request.threadPool(pool1); request.threadPool(pool2); assertNotNull(request); }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) -
src/test/java/org/codelibs/curl/io/IOIntegrationTest.java
assertNotNull(threadName.get()); // The async execution should have run on a ForkJoinPool thread, not the main thread assertTrue("Should run on ForkJoinPool thread: " + threadName.get(), threadName.get().contains("ForkJoinPool") || !threadName.get().equals(Thread.currentThread().getName())); pool.shutdown(); }
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) -
src/main/java/org/codelibs/curl/CurlRequest.java
import java.net.HttpURLConnection; import java.net.Proxy; import java.net.URL; import java.net.URLEncoder; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ForkJoinPool; import java.util.function.BiConsumer; import java.util.function.Consumer; import java.util.function.Supplier; import java.util.logging.Logger; import java.util.zip.GZIPInputStream;
Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 09:11:12 GMT 2026 - 19.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java
assertEquals(result, crawlingInfoHelper.generateId(dataMap)); final AtomicInteger counter = new AtomicInteger(0); final ForkJoinPool pool = new ForkJoinPool(10); for (int i = 0; i < 1000; i++) { pool.execute(() -> { assertEquals(result, crawlingInfoHelper.generateId(dataMap)); counter.incrementAndGet();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 12 01:46:45 GMT 2026 - 28.7K bytes - Click Count (0)