- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 157 for complete (0.23 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* Clears fields that are no longer needed after this future has completed -- or at least all its * inputs have completed (more precisely, after {@link #handleAllCompleted()} has been called). * Often called multiple times (that is, both when the inputs complete and when the output * completes). * * <p>This is similar to our proposed {@code afterCommit} method but not quite the same. See the * description of CL 265462958. */
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) -
guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
public void complete(RuntimeException e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this); } } public void complete(Error e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this); } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 12 20:02:10 GMT 2018 - 3.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SpnegoContext.java
} else if ( targ.getResult() != NegTokenTarg.ACCEPT_COMPLETED ) { throw new SmbException("SPNEGO negotiation did not complete"); } verifyMechListMIC(targ.getMechanismListMIC()); this.completed = true; return null; } if ( inputToken == null ) { return initialToken();
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Mon Jan 04 04:18:31 GMT 2021 - 14.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
private static final String RESULT_DATA = "SUCCESS"; private SettableFuture<String> outputFuture; // Signals that the function is waiting to complete private CountDownLatch funcIsWaitingLatch; // Signals the function so it will complete private CountDownLatch funcCompletionLatch; @Override protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
public void complete(RuntimeException e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this); } } public void complete(Error e) { if (!super.setException(new WrapperException(checkNotNull(e)))) { throw new IllegalStateException("Future was already complete: " + this); } }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 12 20:02:10 GMT 2018 - 3.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
return; } ListenableFuture<V> delegate = timeoutFuture.delegateRef; if (delegate == null) { return; } /* * If we're about to complete the TimeoutFuture, we want to release our reference to it. * Otherwise, we'll pin it (and its result) in memory until the timeout task is GCed. (The
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) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertTrue(listenerLatch.await(200, MILLISECONDS)); latch.countDown(); exec.shutdown(); exec.awaitTermination(100, MILLISECONDS); } /** * Tests that all listeners complete, even if they were added before or after the future was * finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
/** * Do interruptible work here - do not complete Futures here, as their listeners could be * interrupted. */ @ParametricNullness abstract T runInterruptibly() throws Exception; /** * Any interruption that happens as a result of calling interruptTask will arrive before this * method is called. Complete Futures here. */
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/src/com/google/common/util/concurrent/MoreExecutors.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone() * complete} or, if the computation is already complete, immediately. * * <p>There is no guaranteed ordering of execution of listeners, but any listener added through * this method is guaranteed to be called once the computation is complete. * * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0)