- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 688 for Thread (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)