- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 614 for threads (0.07 sec)
-
guava/src/com/google/common/collect/ForwardingList.java
* invoke methods, they invoke methods on the {@code ForwardingList}. * * <p>The {@code standard} methods and any collection views they return are not guaranteed to be * thread-safe, even when all of the methods that they depend on are thread-safe. * * @author Mike Bostock * @author Louis Wasserman * @since 2.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 15:26:39 UTC 2023 - 7.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
} } } private static class Interrupter implements Runnable { final Thread threadToInterrupt; Interrupter(Thread threadToInterrupt) { this.threadToInterrupt = threadToInterrupt; } @Override public void run() { try { Thread.sleep(100); } catch (InterruptedException e) { throw new AssertionError(); } finally {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 12.1K bytes - Viewed (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() { throw RuntimeException("boom!") } } thread.start() thread.join() assertFailsWith<AssertionError> { testRule.afterEach(extensionContext) }.also { expected ->
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.7K bytes - Viewed (0) -
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>
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 15.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
final CountDownLatch doneSignal = new CountDownLatch(1); Thread thread = new Thread() { @Override public void run() { try { cacheRef.get().getUnchecked(3); } finally { doneSignal.countDown(); } } }; thread.setUncaughtExceptionHandler( new UncaughtExceptionHandler() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 12.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
final CountDownLatch doneSignal = new CountDownLatch(1); Thread thread = new Thread() { @Override public void run() { try { cacheRef.get().getUnchecked(3); } finally { doneSignal.countDown(); } } }; thread.setUncaughtExceptionHandler( new UncaughtExceptionHandler() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 12.4K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
} private static void interruptThreadSafely ( QueryThread thread ) { try { thread.interrupt(); } catch ( SecurityException e ) { e.printStackTrace(); } } private static void joinThread ( Thread thread ) { try { thread.join(); } catch ( InterruptedException e ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Aug 14 14:26:22 UTC 2022 - 38.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
} @J2ktIncompatible @GwtIncompatible // Thread.interrupt public void testGetUnchecked_interrupted() { Thread.currentThread().interrupt(); try { assertEquals("foo", getUnchecked(immediateFuture("foo"))); assertTrue(Thread.currentThread().isInterrupted()); } finally { Thread.interrupted(); } } public void testGetUnchecked_cancelled() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java
} @J2ktIncompatible @GwtIncompatible // Thread.interrupt public void testGetUnchecked_interrupted() { Thread.currentThread().interrupt(); try { assertEquals("foo", getUnchecked(immediateFuture("foo"))); assertTrue(Thread.currentThread().isInterrupted()); } finally { Thread.interrupted(); } } public void testGetUnchecked_cancelled() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 4.4K bytes - Viewed (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(); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.3K bytes - Viewed (0)