Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 688 for Thread (0.03 sec)

  1. guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

              @Override
              public Thread newThread(Runnable r) {
                Thread thread = new Thread(r);
                thread.setName(THREAD_NAME);
                thread.setPriority(THREAD_PRIORITY);
                thread.setDaemon(THREAD_DAEMON);
                thread.setUncaughtExceptionHandler(UNCAUGHT_EXCEPTION_HANDLER);
                return thread;
              }
            };
    
        Thread thread =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/opensearch/client/CrawlerEngineClientTest.java

        }
    
        // Test constructor with different thread context
        public void test_constructorInDifferentThread() throws Exception {
            // Test that constructor works in different thread
            final CrawlerEngineClient[] clientHolder = new CrawlerEngineClient[1];
            final Exception[] exceptionHolder = new Exception[1];
    
            Thread thread = new Thread(() -> {
                try {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

            .connectionPool(ConnectionPool(connectionListener = connectionListener))
        }
    
      private fun loomThreadFactory(): ThreadFactory {
        val ofVirtual = Thread::class.java.getMethod("ofVirtual").invoke(null)
    
        return Class
          .forName("java.lang.Thread\$Builder")
          .getMethod("factory")
          .invoke(ofVirtual) as ThreadFactory
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/tests/persistent/HandleInfoTest.java

                    null);
    
            assertFalse(durableInfo.isExpired());
    
            // Wait for expiration
            try {
                Thread.sleep(150);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
    
            assertTrue(durableInfo.isExpired());
    
            // Test persistent handle (never expires)
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  5. README.md

        service.setPort(9200);
    });
    ```
    
    ## Performance Tuning
    
    ### Thread Configuration
    
    ```java
    // Optimize thread pool settings
    crawler.crawlerContext.setNumOfThread(20);           // Number of crawler threads
    crawler.crawlerContext.setMaxThreadCheckCount(50);   // Thread monitoring frequency
    ```
    
    ### Connection Pool Tuning
    
    ```java
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *   <li>a {@linkplain ThreadFactoryBuilder#setNameFormat naming format}
     *   <li>a {@linkplain Thread#setPriority thread priority}
     *   <li>an {@linkplain Thread#setUncaughtExceptionHandler uncaught exception handler}
     *   <li>a {@linkplain ThreadFactory#newThread backing thread factory}
     * </ul>
     *
     * <p>If no backing thread factory is provided, a default backing thread factory is used as if by
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:35:26 UTC 2025
    - 9K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

            // be ignored; see tryClose comment.
            if (socket == null) {
                socket = new DatagramSocket(lport, laddr);
                thread = new Thread(this, "JCIFS-NameServiceClient");
                thread.setDaemon(true);
                thread.start();
            }
        }
    
        void tryClose() {
            synchronized (LOCK) {
    
                /* Yes, there is the potential to drop packets
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

        /**
         * Interval in milliseconds between crawler thread executions.
         * Used to control the rate at which new crawler threads are started
         * and the frequency of status checks.
         */
        protected long crawlingExecutionInterval = Constants.DEFAULT_CRAWLING_EXECUTION_INTERVAL;
    
        /**
         * Thread priority for crawler threads.
         * Defaults to normal thread priority.
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

                }
                currentProcess = null;
    
            }
        }
    
        /**
         * Monitor thread that handles process timeout and termination.
         * This thread sleeps for the specified timeout duration and terminates the process if it hasn't finished.
         */
        protected static class MonitorThread extends Thread {
            /** The process to monitor. */
            private final Process process;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

                            successCount.incrementAndGet();
                        }
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    } finally {
                        endLatch.countDown();
                    }
                }
            });
    
            Thread thread2 = new Thread(new Runnable() {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
Back to top