- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 138 for Stopping (0.15 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ServiceTest.java
assertLessThan(NEW, TERMINATED); assertLessThan(STARTING, RUNNING); assertLessThan(STARTING, STOPPING); assertLessThan(STARTING, FAILED); assertLessThan(RUNNING, STOPPING); assertLessThan(RUNNING, FAILED); assertLessThan(STOPPING, FAILED); assertLessThan(STOPPING, TERMINATED); } private static <T extends Comparable<? super T>> void assertLessThan(T a, T b) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.9K bytes - Viewed (0) -
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) -
guava-tests/test/com/google/common/util/concurrent/ServiceTest.java
assertLessThan(NEW, TERMINATED); assertLessThan(STARTING, RUNNING); assertLessThan(STARTING, STOPPING); assertLessThan(STARTING, FAILED); assertLessThan(RUNNING, STOPPING); assertLessThan(RUNNING, FAILED); assertLessThan(STOPPING, FAILED); assertLessThan(STOPPING, TERMINATED); } private static <T extends Comparable<? super T>> void assertLessThan(T a, T b) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.9K 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) -
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) -
testing/internal-integ-testing/src/main/groovy/org/bbottema/javasocksproxyserver/TestRecordingSocksServer.java
} public synchronized void start(int listenPort, ServerSocketFactory serverSocketFactory) { this.stopping = false; new Thread(new ServerProcess(listenPort, serverSocketFactory)).start(); } public synchronized void stop() { stopping = true; } private class ServerProcess implements Runnable { protected final int port;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/test/loadbalancersim/timer/queue.go
package timer import ( "container/heap" "sync" "time" ) type Queue struct { heap timerHeap mutex sync.Mutex stopCh chan struct{} resetTimerCh chan struct{} stopping bool timer *time.Timer currentDeadline time.Time } func NewQueue() *Queue { q := &Queue{ heap: make(timerHeap, 0), timer: time.NewTimer(1 * time.Minute),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 3.6K bytes - Viewed (0)