Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for ForkJoinPool (0.06 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to Top