- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 304 for listeners (0.17 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue()); assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); assertTrue(task.isDone());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/EventSpyImpl.java
InternalMavenSession.from(ee.getSession().getSession()); Collection<Listener> listeners = session.getListeners(); if (!listeners.isEmpty()) { Event event = new DefaultEvent(session, ee); for (Listener listener : listeners) { listener.onEvent(event); } } } } @Override
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 2.1K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
checkNotNull(unit); return get(); } @Override public void addListener(Runnable runnable, Executor executor) { Listener listener = new Listener(runnable, executor); if (isDone()) { listener.execute(); } else { listeners.add(listener); } } @CanIgnoreReturnValue protected boolean setException(Throwable throwable) { checkNotNull(throwable);
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/JdkFutureAdapters.java
return delegate; } @Override public void addListener(Runnable listener, Executor exec) { executionList.add(listener, exec); // When a listener is first added, we run a task that will wait for the delegate to finish, // and when it is done will run the listeners. if (hasListeners.compareAndSet(false, true)) { if (delegate.isDone()) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 7.5K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
// won't happen } } if (listeners == null) { listeners = new ArrayList<>(); if (logger.isDebugEnabled()) { listeners.add(new DebugResolutionListener(logger)); } listeners.add(new WarningResolutionListener(logger)); }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 05:46:50 GMT 2024 - 24.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* across calls to multiple listeners. Specifically, a given listener will have its callbacks * invoked in the same order as the underlying service enters those states. Additionally, at most * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks * may execute concurrently, and listeners may execute in an order different from the one in which * they were registered.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 10.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* MoreExecutors#directExecutor}. Otherwise, avoid it: See the warnings on the docs for {@code * directExecutor}. * * <p>This is the most general listener interface. For common operations performed using * listeners, see {@link Futures}. For a simplified but general listener interface, see {@link * Futures#addCallback addCallback()}. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
RecordingListener listener = new RecordingListener(); manager.addListener(listener, directExecutor()); manager.startAsync().awaitHealthy(); assertTrue(manager.isHealthy()); assertTrue(listener.healthyCalled); assertFalse(listener.stoppedCalled); assertTrue(listener.failedServices.isEmpty()); manager.stopAsync().awaitStopped();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
istioctl proxy-config listeners <pod-name[.namespace]> --port 9080 # Retrieve full listener dump for HTTP listeners with a wildcard address (0.0.0.0). istioctl proxy-config listeners <pod-name[.namespace]> --type HTTP --address 0.0.0.0 -o json # Retrieve listener summary without using Kubernetes API ssh <user@hostname> 'curl localhost:15000/config_dump' > envoy-config.json
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
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. */ public void testAllListenersCompleteSuccessfully()
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0)