- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 349 for Stopping (0.15 sec)
-
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java
lock.lock(); try { switch (state) { case RUNNING: break; case STOPPING: throw new IllegalStateException(String.format("Cannot use %s as it is currently stopping.", displayName)); case STOPPED: throw new IllegalStateException(String.format("Cannot use %s as it has been stopped.", displayName));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/AsyncStoppable.java
* It should, however, stop accepting new work.</p> * * <p> * Requesting stopping does not guarantee the stoppable actually stops. * Requesting stopping means preparing for stopping; stopping accepting new work. * You have to call stop at some point anyway if your intention is to completely stop the stoppable. */ void requestStop();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
assertFalse(service.isRunning()); assertTrue(service.doStartCalled); service.stopAsync(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertFalse(service.doStopCalled); service.notifyStarted(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertTrue(service.doStopCalled); service.notifyStopped();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 29.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
assertFalse(service.isRunning()); assertTrue(service.doStartCalled); service.stopAsync(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertFalse(service.doStopCalled); service.notifyStarted(); assertEquals(State.STOPPING, service.state()); assertFalse(service.isRunning()); assertTrue(service.doStopCalled); service.notifyStopped();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 29.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
public void finished(ConnectionState connectionState) { connections.remove(connectionState); if (stopping) { maybeStop(); } } /** * Called when no further incoming connections will be added. */ public void noFurtherConnections() { stopping = true; maybeStop(); } private void maybeStop() { if (connections.isEmpty()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
src/os/signal/signal.go
// quiesce before fully removing it. handlers.stopping = append(handlers.stopping, stopping{c, h}) handlers.Unlock() signalWaitUntilIdle() handlers.Lock() for i, s := range handlers.stopping { if s.c == c { handlers.stopping = append(handlers.stopping[:i], handlers.stopping[i+1:]...) break } } handlers.Unlock() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/Connection.java
* <ul> * <li>should allow separate threads for dispatching and receiving, i.e. single thread that dispatches * and a different single thread that receives should be perfectly safe</li> * <li>should allow stopping or requesting stopping from a different thread than receiving/dispatching</li> * <li>don't guarantee allowing multiple threads dispatching</li> * </ul> */ public interface Connection<T> extends Dispatch<T>, Receive<T>, Stoppable {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/async/ServiceLifecycleTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 6.2K bytes - Viewed (0)