- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 805 for threadId (0.06 seconds)
-
src/main/java/org/codelibs/fess/suggest/SuggesterBuilder.java
} /** * Sets the thread pool. * @param threadPool The thread pool. * @return This builder instance. */ public SuggesterBuilder threadPool(final ExecutorService threadPool) { this.threadPool = threadPool; return this; } /** * Sets the thread pool size. * @param threadPoolSize The thread pool size. * @return This builder instance.Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 6.2K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// // TODO(user): Consider using // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage() // // TODO(user): Consider scaling by number of mutator threads, // e.g. using Thread#activeCount() return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L)); } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 20:19:19 GMT 2026 - 12.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
private fun sleep(delayMillis: Int) { try { Thread.sleep(delayMillis.toLong()) } catch (e: InterruptedException) { Thread.currentThread().interrupt() } } private fun cancelLater( call: Call, delayMillis: Int, ): CountDownLatch { val latch = CountDownLatch(1) Thread { sleep(delayMillis) if (cancelMode == CANCEL) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 9.4K bytes - Click Count (0) -
okhttp-testing-support/src/test/kotlin/okhttp3/OkHttpClientTestRuleTest.kt
} @Test fun uncaughtException() { val testRule = OkHttpClientTestRule() testRule.beforeEach(extensionContext) val thread = object : Thread() { override fun run(): Unit = throw RuntimeException("boom!") } thread.start() thread.join() assertFailsWith<AssertionError> { testRule.afterEach(extensionContext) }.also { expected ->
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.7K bytes - Click Count (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
} private static void interruptThreadSafely(final QueryThread thread) { try { thread.interrupt(); } catch (final SecurityException e) { log.error("Security exception interrupting thread", e); } } private static void joinThread(final Thread thread) { try { thread.join(); } catch (final InterruptedException e) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 38.5K bytes - Click Count (0) -
android/guava/src/com/google/common/base/FinalizableReferenceQueue.java
* * Finalizer Thread runs instance of -> Finalizer.class loaded by -> Application class loader * which loaded -> ReferenceMap.class which has a static -> FinalizableReferenceQueue instance * * Even if no other references to classes from the application class loader remain, the Finalizer * thread keeps an indirect strong reference to the queue in ReferenceMap, which keeps the
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 19:26:59 GMT 2026 - 15.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/ResourcesTest.java
ClassLoader oldContextLoader = Thread.currentThread().getContextClassLoader(); try { Thread.currentThread().setContextClassLoader(loader); URL url = Resources.getResource(tempFile.getName()); String text = Resources.toString(url, UTF_8); assertThat(text).isEqualTo("rud a chur ar an méar fhada" + System.lineSeparator()); } finally { Thread.currentThread().setContextClassLoader(oldContextLoader);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 6.9K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java
// Poll for thread to process exceptions for (int i = 0; i < 20; i++) { if (!indexUpdater.isAlive() || indexUpdater.getState() == Thread.State.WAITING || indexUpdater.getState() == Thread.State.TIMED_WAITING) { break; } Thread.sleep(100); } // Clean up the thread indexUpdater.setFinishCrawling(true);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 33.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/IntervalControlHelperTest.java
// Start a thread to set crawler running after a delay Thread thread = new Thread(() -> { try { Thread.sleep(100); helper.setCrawlerRunning(true); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }); thread.start();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 13.6K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbCopyUtilTest.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 12.1K bytes - Click Count (0)