- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 638 for threadId (0.05 sec)
-
src/test/java/org/codelibs/fess/util/SystemUtilTest.java
// Start all threads for (Thread thread : threads) { thread.start(); } // Wait for all threads to complete for (Thread thread : threads) { try { thread.join(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); fail("Thread interrupted");
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 12.9K bytes - Viewed (0) -
src/test/java/jcifs/EmptyIteratorTest.java
}); threads[i].start(); } // Wait for all threads to complete for (Thread thread : threads) { thread.join(); } } // Then for (int i = 0; i < threadCount; i++) { assertTrue(results[i], "Thread " + i + " should have completed successfully"); } }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public @Nullable Void call() throws Exception { assertEquals(Thread.currentThread().getName(), newName.get()); return null; } }; Callables.threadRenaming(callable, newName).call(); assertEquals(oldName, Thread.currentThread().getName()); } @J2ktIncompatible @GwtIncompatible // threads public void testRenaming_exceptionalReturn() throws Exception {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
.forEach(s -> buf.append(s)); log(buf); } /** * Increments the thread reference count for the specified crawler object. * Used when the same object is being processed on multiple threads. * * @param keyObj the crawler object running on an additional thread */ public void runOnThread(final Object keyObj) { getCacheKey(keyObj).ifPresent(key -> {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 17.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/mylasta/direction/FessConfigImplTest.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 12.6K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java
// Test thread safety Thread[] threads = new Thread[10]; for (int i = 0; i < threads.length; i++) { threads[i] = new Thread(() -> { channelManager.getChannels(); channelManager.getHealthyChannels(); channelManager.getLoadBalancer(); }); threads[i].start(); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.6K bytes - Viewed (0) -
src/test/java/jcifs/context/BaseContextTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 15.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Striped64.java
* there would exist a perfect hash function mapping threads to * slots that eliminates collisions. When we reach capacity, we * search for this mapping by randomly varying the hash codes of * colliding threads. Because search is random, and collisions * only become known via CAS failures, convergence can be slow, * and because threads are typically not bound to CPUS forever, * may not occur at all. However, despite these limitations,
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jan 15 22:17:15 UTC 2025 - 11.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeTest.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.4K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerStatusTest.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 15.8K bytes - Viewed (0)