- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for runInterruptibly (0.32 sec)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* before, during, or after runInterruptibly() (unless it produced an InterruptedException * caught above) can linger and affect listeners. */ } /** * Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not * be called. */ abstract boolean isDone(); /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task = new InterruptibleTask<@Nullable Void>() { @Override @Nullable Void runInterruptibly() throws Exception { BrokenChannel bc = new BrokenChannel(); bc.doBegin(); isInterruptibleRegistered.countDown();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task = new InterruptibleTask<@Nullable Void>() { @Override @Nullable Void runInterruptibly() throws Exception { BrokenChannel bc = new BrokenChannel(); bc.doBegin(); isInterruptibleRegistered.countDown();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
super(listenerExecutor); this.callable = checkNotNull(callable); } @Override ListenableFuture<V> runInterruptibly() throws Exception { ListenableFuture<V> result = callable.call(); return checkNotNull( result, "AsyncCallable.call returned null instead of a Future. "
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
return FuturesGetChecked.getChecked(future, exceptionClass, timeout, unit); } /** * Returns the result of calling {@link Future#get()} uninterruptibly on a task known not to throw * a checked exception. This makes {@code Future} more suitable for lightweight, fast-running * tasks that, barring bugs in the code, will not fail. This gives it exception-handling behavior
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
loadingValueReference.setException(t); } }, directExecutor()); return loadingFuture; } /** Waits uninterruptibly for {@code newValue} to be loaded, and then records loading stats. */ @CanIgnoreReturnValue V getAndRecordStats( K key, int hash,
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 150.3K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
loadingValueReference.setException(t); } }, directExecutor()); return loadingFuture; } /** Waits uninterruptibly for {@code newValue} to be loaded, and then records loading stats. */ @CanIgnoreReturnValue V getAndRecordStats( K key, int hash,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K bytes - Viewed (0)