- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 664 for threadId (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* The particular nature and strength of the guarantees made by the proxy is * implementation-dependent. However, it is important that each of the methods on the target * object behaves appropriately when its thread is interrupted. * * <p>For example, to return the value of {@code target.someMethod()}, but substitute {@code * DEFAULT_VALUE} if this method call takes over 50 ms, you can use this code: * * <pre>Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 8.2K bytes - Click Count (0) -
docs/features/calls.md
Calls are executed in one of two ways: * **Synchronous:** your thread blocks until the response is readable. * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/5.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 3.9K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java
@Test void testActivityTracking() { long initialTime = channelInfo.getLastActivityTime(); // Wait a bit and update activity try { Thread.sleep(10); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } channelInfo.updateActivity(); assertTrue(channelInfo.getLastActivityTime() > initialTime);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 7.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/script/groovy/GroovyEngine.java
* and DI container integration. * * <p>Thread Safety: This class is thread-safe. Each cached entry holds its own * GroovyClassLoader. The cache uses Guava Cache with segment-based locking for * lock-free concurrent reads. Each evaluate() call creates a new Script instance * to ensure thread isolation of bindings.</p> *
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 14:36:23 GMT 2026 - 11.9K bytes - Click Count (0) -
compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java
private List<File> filesToDelete = new ArrayList<>(); private final String baseFilename; private final String fileSuffix; private StackTraceElement callerInfo; private Thread cleanupWarning; private boolean warnAboutCleanup = false; public TestFileManager(String baseFilename, String fileSuffix) { this.baseFilename = baseFilename; this.fileSuffix = fileSuffix;Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Sep 17 10:01:14 GMT 2025 - 4.8K bytes - Click Count (0) -
TESTING.asciidoc
case, and another test for the 2+ shards case. ==== Abuse randomization in multi-threaded tests Multi-threaded tests are often not reproducible due to the fact that there is no guarantee on the order in which operations occur across threads. Adding randomization to the mix usually makes things worse and should be done with care. == Test coverage analysis
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Mon Jun 07 13:55:20 GMT 2021 - 32.5K bytes - Click Count (0) -
guava/src/com/google/common/collect/Interners.java
/* Someone beat us to it! Trying again... * * Technically this loop not guaranteed to terminate, so theoretically (extremely * unlikely) this thread might starve, but even then, there is always going to be another * thread doing progress here. */ } } } } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 16:16:42 GMT 2026 - 6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
Thread.currentThread().interrupt(); try { getChecked(future, TwoArgConstructorException.class); fail(); } catch (TwoArgConstructorException expected) { assertThat(expected).hasCauseThat().isInstanceOf(InterruptedException.class); assertTrue(Thread.currentThread().isInterrupted()); } finally { Thread.interrupted(); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
Thread.currentThread().interrupt(); try { getChecked(future, TwoArgConstructorException.class); fail(); } catch (TwoArgConstructorException expected) { assertThat(expected).hasCauseThat().isInstanceOf(InterruptedException.class); assertTrue(Thread.currentThread().isInterrupted()); } finally { Thread.interrupted(); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.5K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/LongAdder.java
* (method {@link #add}) are contended across threads, the set of variables may grow dynamically to * reduce contention. Method {@link #sum} (or, equivalently, {@link #longValue}) returns the current * total combined across the variables maintaining the sum. * * <p>This class is usually preferable to {@link AtomicLong} when multiple threads update a commonCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 20 13:05:10 GMT 2025 - 5.5K bytes - Click Count (0)