- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 194 for STOPPED (0.21 sec)
-
guava/src/com/google/common/util/concurrent/Service.java
* this initiates service shutdown and returns immediately. If the service is {@linkplain * State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been started nor * stopped. If the service has already been stopped, this method returns immediately without * taking action. * * @return this * @since 15.0 */ @CanIgnoreReturnValue Service stopAsync(); /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 31.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandler.java
private FileLockCommunicator communicator; private ManagedExecutor fileLockRequestListener; private ManagedExecutor unlockActionExecutor; private boolean stopped; public DefaultFileLockContentionHandler(ExecutorFactory executorFactory, InetAddressProvider inetAddressProvider) { this.executorFactory = executorFactory; this.inetAddressProvider = inetAddressProvider;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 12.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
e.message == 'Cannot create outgoing dispatch, as <hub> has been stopped.' } def "cannot add handler after stop started"() { when: hub.requestStop() hub.addHandler("channel", new Object()) then: IllegalStateException e = thrown() e.message == 'Cannot add handler, as <hub> has been stopped.' } def "cannot add connection after stop started"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
return new ThreadHandleImpl(thread); } private void testThreadStarted(Thread thread) { lock.lock(); try { if (stopped) { throw new IllegalStateException("Cannot start new threads, as this test case has been stopped."); } LOGGER.debug("Started {}", thread); active.add(thread); condition.signalAll(); } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
// used to lock the observedRecord observedRecordLock sync.Mutex metrics leaderMetricsAdapter } // Run starts the leader election loop. Run will not return // before leader election loop is stopped by ctx or it has // stopped holding the leader lease func (le *LeaderElector) Run(ctx context.Context) { defer runtime.HandleCrash() defer func() { le.config.Callbacks.OnStoppedLeading() }() if !le.acquire(ctx) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
src/runtime/time.go
// timerZombie is set when the timer has been stopped // but is still present in some P's heap. // Only set when timerHeaped is also set. // It is possible for timerModified and timerZombie to both // be set, meaning that the timer was modified and then stopped. // A timer sending to a channel may be placed in timerZombie // to take it out of the heap even though the timer is not stopped, // as long as nothing is reading from the channel.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
return count == 2, nil }); err != nil { t.Fatalf("expected forget() to be called twice, first call from w.add() and then from w.Stop() called from w.processInterval(): %v", err) } if !w.stopped { t.Fatal("expected the watcher to be stopped but it wasn't") } } // TestCacheWatcherDrainingNoBookmarkAfterResourceVersionSent checks if the watcher's input
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
} /** * Starts the daemon, receiving connections asynchronously (i.e. returns immediately). * * @throws IllegalStateException if this daemon is already running, or has already been stopped. */ public void start() { LOGGER.info("start() called on daemon - {}", daemonContext); lifecycleLock.lock(); try { if (stateCoordinator != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0) -
platforms/core-runtime/daemon-server/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonMain.java
import java.util.List; /** * The entry point for a daemon process. * * If the daemon hits the specified idle timeout the process will exit with 0. If the daemon encounters an internal error or is explicitly stopped (which can be via receiving a stop command, or * unexpected client disconnection) the process will exit with 1. */ public class DaemonMain extends EntryPoint {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.8K bytes - Viewed (0)