- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 213 for AddListener (0.42 sec)
-
platforms/core-runtime/process-services/src/test/groovy/org/gradle/process/internal/health/memory/DefaultMemoryManagerTest.groovy
* Registers an OS memory status update to initialize the values. */ def newMemoryManager(OsMemoryInfo memoryInfo) { def listenerManager = Mock(ListenerManager) { 1 * addListener(_) >> { args -> osMemoryStatusListener = args[0] } } def memoryManager = new DefaultMemoryManager(memoryInfo, jvmMemoryInfo, listenerManager, Stub(ExecutorFactory), 0.25, false)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 20 23:56:19 UTC 2023 - 9.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
* * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See * the discussion in the {@link ListenableFuture#addListener ListenableFuture.addListener} * documentation. */ public void add(Runnable runnable, Executor executor) { // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { CatchingFuture<V, X> future = new CatchingFuture<>(input, exceptionType, fallback); input.addListener(future, rejectionPropagatingExecutor(executor, future)); return future; } static <X extends Throwable, V extends @Nullable Object> ListenableFuture<V> create( ListenableFuture<? extends V> input,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
), } if err := ret.loadCertKeyPair(); err != nil { return nil, err } return ret, nil } // AddListener adds a listener to be notified when the serving cert content changes. func (c *DynamicCertKeyPairContent) AddListener(listener Listener) { c.listeners = append(c.listeners, listener) } // loadCertKeyPair determines the next set of content for the file.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/secure_serving.go
s.SNICerts, nil, // TODO see how to plumb an event recorder down in here. For now this results in simply klog messages. ) if s.ClientCA != nil { s.ClientCA.AddListener(dynamicCertificateController) } if s.Cert != nil { s.Cert.AddListener(dynamicCertificateController) } // generate a context from stopCh. This is to avoid modifying files which are relying on apiserver
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 20:54:07 UTC 2023 - 10.3K bytes - Viewed (0) -
platforms/extensibility/plugin-use/src/main/java/org/gradle/plugin/management/internal/DefaultPluginResolutionStrategy.java
private final Map<PluginId, String> pluginVersions = new HashMap<>(); private boolean locked; public DefaultPluginResolutionStrategy(ListenerManager listenerManager) { listenerManager.addListener(new InternalBuildAdapter(){ @Override public void projectsLoaded(Gradle gradle) { locked = true; } }); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 2.7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/connection/ProgressLoggingConsumerActionExecutor.java
ProgressListenerAdapter listener = new ProgressListenerAdapter(parameters.getProgressListener()); ListenerManager listenerManager = loggingProvider.getListenerManager(); listenerManager.addListener(listener); try { ProgressLogger progressLogger = loggingProvider.getProgressLoggerFactory().newOperation(ProgressLoggingConsumerActionExecutor.class); progressLogger.setDescription("Build");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
import java.util.concurrent.Executor; import java.util.logging.Level; /** * A list of listeners for implementing a concurrency friendly observable object. * * <p>Listeners are registered once via {@link #addListener} and then may be invoked by {@linkplain * #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events. * * <p>The API of this class is designed to make it easy to achieve the following properties * * <ul>
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
private final ListenableFuture<?> future; public MockFutureListener(ListenableFuture<?> future) { this.countDownLatch = new CountDownLatch(1); this.future = future; future.addListener(this, directExecutor()); } @Override public void run() { countDownLatch.countDown(); } /** * Verify that the listener completes in a reasonable amount of time, and Asserts that the future
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:12:42 UTC 2023 - 3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java
this.exec = Executors.newCachedThreadPool(); this.future = checkNotNull(future); this.latch = new CountDownLatch(1); } public void setUp() { future.addListener( new Runnable() { @Override public void run() { latch.countDown(); } }, exec); assertEquals(1, latch.getCount());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.3K bytes - Viewed (0)