- Sort Score
- Num 10 results
- Language All
Results 191 - 200 of 890 for thread (0.19 seconds)
-
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/builtin/BuiltinShellCommandRegistryFactory.java
builder.directory(shellContext.cwd.get().toFile()); Process process = builder.start(); Thread out = new Thread(new StreamGobbler(process.getInputStream(), shellContext.writer)); Thread err = new Thread(new StreamGobbler(process.getErrorStream(), shellContext.logger::error)); out.start(); err.start();
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Jun 07 06:22:47 GMT 2025 - 12.3K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
* instances is using {@link CacheBuilder}. * * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed * by multiple concurrent threads. * * <p>When evaluated as a {@link Function}, a cache yields the same result as invoking {@link * #getUnchecked}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8.5K bytes - Click Count (0) -
guava/src/com/google/common/cache/Cache.java
* evicted or manually invalidated. The common way to build instances is using {@link CacheBuilder}. * * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed * by multiple concurrent threads. * * @param <K> the type of the cache's keys, which are not permitted to be null * @param <V> the type of the cache's values, which are not permitted to be null * @author Charles FryCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java
prev = x; } } } /** compareAndSet in one thread enables another waiting for value to succeed */ public void testCompareAndSetInMultipleThreads() throws InterruptedException { AtomicDoubleArray a = new AtomicDoubleArray(1); a.set(0, 1.0); Thread t = newStartedThread( new CheckedRunnable() { @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 14.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
Thread thread = new Thread() { @Override public void run() { try { cacheRef.get().getUnchecked(3); } finally { doneSignal.countDown(); } } }; thread.setUncaughtExceptionHandler((t, throwable) -> {}); thread.start();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 13.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
Thread thread = new Thread() { @Override public void run() { try { cacheRef.get().getUnchecked(3); } finally { doneSignal.countDown(); } } }; thread.setUncaughtExceptionHandler((t, throwable) -> {}); thread.start();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 13.1K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/TestLockingTest.java
t.url = args[ai]; } } assertEquals(expectedUrl, t.url, "URL should be correctly parsed"); assertEquals(2, t.numThreads, "Thread count should be parsed"); assertEquals(5, t.numIter, "Iteration count should be parsed"); assertEquals(100L, t.delay, "Delay should be parsed"); } @Test
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
} /** * Creates a TimeLimiter instance using the given executor service to execute method calls. * * <p><b>Warning:</b> using a bounded executor may be counterproductive! If the thread pool fills * up, any time callers spend waiting for a thread may count toward their time limit, and in this * case the call may even time out before the target method is ever invoked. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 9.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* example involving two locks and two threads, deadlock occurs when one thread acquires Lock A, and * then Lock B, while another thread acquires Lock B, and then Lock A: * * <pre> * Thread1: acquire(LockA) --X acquire(LockB) * Thread2: acquire(LockB) --X acquire(LockA) * </pre> * * <p>Neither thread will progress because each is waiting for the other. In more complex
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 36K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
assertBitEquals(x, at.get()); prev = x; } } /** compareAndSet in one thread enables another waiting for value to succeed */ public void testCompareAndSetInMultipleThreads() throws Exception { AtomicDouble at = new AtomicDouble(1.0); Thread t = newStartedThread( new CheckedRunnable() { @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10.6K bytes - Click Count (0)