- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 247 for InterruptedException (0.08 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
verifyTimedGetOnPendingFuture(future); } private static void assertSuccessful( AbstractFuture<Integer> future, @Nullable Integer expectedResult) throws InterruptedException, TimeoutException, ExecutionException { assertDone(future); assertThat(future.isCancelled()).isFalse(); assertThat(getDone(future)).isEqualTo(expectedResult);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 15.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
} responseQueue.put(new Response(request.methodName, result, null)); } } catch (ThreadDeath death) { return; } catch (InterruptedException ignored) { // SynchronousQueue sometimes throws InterruptedException while the threads are stopping. } catch (Throwable uncaught) { this.uncaughtThrowable = uncaught; } } private static class Request {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.8K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
} }); assertTrue(map.isEmpty()); } // ---------------------------------------------------------------- // Test that interrupts result in RuntimeException, not InterruptedException. // Trickier than it looks, because runFinalization swallows interrupts. // ---------------------------------------------------------------- class Interruptenator extends Thread {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 7.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
return method.getReturnType() == boolean.class; } /** Determines whether the given method can throw InterruptedException. */ private static boolean isInterruptible(Method method) { return Arrays.asList(method.getExceptionTypes()).contains(InterruptedException.class); } /** Sorts the given methods primarily by name and secondarily by number of parameters. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 27K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
finishLatch.await(1, MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, MINUTES); } void releaseLockAndFinish() throws InterruptedException { finishLatch.countDown(); this.join(10000);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
finishLatch.await(1, MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, MINUTES); } void releaseLockAndFinish() throws InterruptedException { finishLatch.countDown(); this.join(10000);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private volatile boolean running = false; @Override public @Nullable Void call() throws InterruptedException { running = true; startLatch.countDown(); stopLatch.await(); running = false; return null; } void waitForStart() throws InterruptedException { startLatch.await(); } void stop() { stopLatch.countDown(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 20:58:01 UTC 2025 - 16.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaErrorHandler.java
log.info("RDMA connection recovery successful after {} attempts", retryCount); return true; } } catch (InterruptedException e) { log.debug("RDMA recovery interrupted"); Thread.currentThread().interrupt(); break; } catch (Exception recoveryError) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 10.5K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
return null; } while (this.inFlightLookups.contains(name)) { try { this.inFlightLookups.wait(); } catch (final InterruptedException e) { log.trace("Interrupted", e); } } } obj = getCachedAddress(name); if (obj == null) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 38.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
public void testSuccess() throws ExecutionException, InterruptedException { Object value = new Object(); assertSame( value, new AbstractFuture<Object>() { { set(value); } }.get()); } public void testException() throws InterruptedException { Throwable failure = new Throwable(); AbstractFuture<String> future =
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0)