- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 37 for async (0.14 sec)
-
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
} @Override public void run() { InterruptibleTask<?> localTask = task; if (localTask != null) { localTask.run(); } /* * In the Async case, we may have called setFuture(pendingFuture), in which case afterDone() * won't have been called yet. */ this.task = null; } @Override protected void afterDone() { super.afterDone();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
} /** * Returns a dispatcher that queues events that are posted in a single global queue. This behavior * matches the original behavior of AsyncEventBus exactly, but is otherwise not especially useful. * For async dispatch, an {@linkplain #immediate() immediate} dispatcher should generally be * preferable. */ static Dispatcher legacyAsync() { return new LegacyAsyncDispatcher(); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
waitUntilClosed(closingFuture); assertStillOpen(closeable1); assertClosed(closeable2, closeable3); } // We don't need to test the happy case for SuccessfulCombiner.call(Async) because it's the same // as Combiner. public void testWhenAllSucceed_call_failedInput() throws Exception { assertFinallyFailsWithException( ClosingFuture.whenAllSucceed(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
callableBlocking.countDown(); // Need to wait for resultFuture to be returned. assertTrue(executor.awaitTermination(10, SECONDS)); // But once the async function has returned a future we can include that in the toString assertThat(futureResult.toString()) .matches( "CombinedFuture@\\w+\\[status=PENDING,"
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
AbstractFuture<String> future = setFutureFuture.get(); setFutureSetSuccess.set(currentFuture.get().setFuture(future)); setFutureCompletionSuccess.set(future.set("hello-async-world")); awaitUnchecked(barrier); } }; final Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet()); Runnable collectResultsRunnable =
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) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
AbstractFuture<String> future = setFutureFuture.get(); setFutureSetSuccess.set(currentFuture.get().setFuture(future)); setFutureCompletionSuccess.set(future.set("hello-async-world")); awaitUnchecked(barrier); } }; final Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet()); Runnable collectResultsRunnable =
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/src/com/google/common/collect/ImmutableBiMap.java
* as implementation details. * * <p>Since the bimap is immutable, ImmutableBiMap doesn't require special logic for keeping the * bimap and its inverse in sync during serialization, the way AbstractBiMap does. */ @J2ktIncompatible // serialization private static class SerializedForm<K, V> extends ImmutableMap.SerializedForm<K, V> {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 22.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
String LDAP_ADMIN_GROUP_OBJECT_CLASSES = "ldap.admin.group.object.classes"; /** The key of the configuration. e.g. true */ String LDAP_ADMIN_SYNC_PASSWORD = "ldap.admin.sync.password"; /** The key of the configuration. e.g. true */ String LDAP_AUTH_VALIDATION = "ldap.auth.validation"; /** The key of the configuration. e.g. -1 */
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Apr 11 02:34:53 GMT 2024 - 459.2K bytes - Viewed (5) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
callableBlocking.countDown(); // Need to wait for resultFuture to be returned. assertTrue(executor.awaitTermination(10, SECONDS)); // But once the async function has returned a future we can include that in the toString assertThat(futureResult.toString()) .matches( "CombinedFuture@\\w+\\[status=PENDING,"
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* AsyncFunction.apply}. Any heavyweight operations should occur in other threads responsible for * completing the returned {@code Future}.) * * <p>The returned {@code Future} attempts to keep its cancellation state in sync with that of the * input future and that of the future returned by the chain function. That is, if the returned * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0)