Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for ForkJoinPool (0.27 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/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java

        protected CommonPoolUtil() {
            // nothing
        }
    
        /**
         * Executes the given task in the common ForkJoinPool.
         *
         * @param task
         *            the task to execute
         */
        public static void execute(final Runnable task) {
            ForkJoinPool.commonPool().execute(() -> {
                final Thread currentThread = Thread.currentThread();
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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