- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for afterDone (0.28 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
input.addListener(future, rejectionPropagatingExecutor(executor, future)); return future; } /* * In certain circumstances, this field might theoretically not be visible to an afterDone() call * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture. */ @CheckForNull @LazyInit ListenableFuture<? extends V> inputFuture; @CheckForNull @LazyInit Class<X> exceptionType;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 8.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
super(futures.size()); this.futures = checkNotNull(futures); this.allMustSucceed = allMustSucceed; this.collectsValues = collectsValues; } @Override protected final void afterDone() { super.afterDone(); ImmutableCollection<? extends Future<?>> localFutures = futures; releaseResources(OUTPUT_FUTURE_DONE); // nulls out `futures` if (isCancelled() & localFutures != null) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 15.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
} private void notifyAndClearListeners() { afterDone(); // TODO(lukes): consider adding the StackOverflowError protection from the server version // TODO(cpovirk): consider clearing this.delegate for (Listener listener : listeners) { listener.execute(); } listeners = null; } protected void afterDone() {} @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// so that the cleanup work is visible to listeners. // afterDone() should be generally fast and only used for cleanup work... but in theory can // also be recursive and create StackOverflowErrors future.afterDone(); // push the current set of listeners onto next next = future.clearListeners(next); future = null;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
input.addListener(output, rejectionPropagatingExecutor(executor, output)); return output; } /* * In certain circumstances, this field might theoretically not be visible to an afterDone() call * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture. */ @CheckForNull @LazyInit ListenableFuture<? extends I> inputFuture; @CheckForNull @LazyInit F function;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// this would be observable from an afterDone callback public void testListenersExecuteImmediately_fromAfterDone() { AbstractFuture<String> f = new AbstractFuture<String>() { @Override protected void afterDone() { final AtomicBoolean ranImmediately = new AtomicBoolean(); addListener(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// this would be observable from an afterDone callback public void testListenersExecuteImmediately_fromAfterDone() { AbstractFuture<String> f = new AbstractFuture<String>() { @Override protected void afterDone() { final AtomicBoolean ranImmediately = new AtomicBoolean(); addListener(
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
ListenableFuture<V> localDelegate = delegate; if (localDelegate != null) { return "delegate=[" + localDelegate + "]"; } return null; } @Override protected void afterDone() { delegate = null; } } /** * Creates a new {@code ListenableFuture} whose value is a list containing the values of all its
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)