- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for stopAsync (0.09 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
service.startAsync().awaitRunning(); enterRun.await(); // to avoid stopping the service until run() is invoked service.stopAsync(); service.stopAsync(); service.stopAsync().awaitTerminated(); assertEquals(Service.State.TERMINATED, service.state()); service.stopAsync().awaitTerminated(); assertEquals(Service.State.TERMINATED, service.state()); executionThread.join(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 12.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
service.startAsync().awaitRunning(); enterRun.await(); // to avoid stopping the service until run() is invoked service.stopAsync(); service.stopAsync(); service.stopAsync().awaitTerminated(); assertEquals(Service.State.TERMINATED, service.state()); service.stopAsync().awaitTerminated(); assertEquals(Service.State.TERMINATED, service.state()); executionThread.join(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 12.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
new Thread() { @Override public void run() { manager.stopAsync().awaitStopped(); } }; stoppingThread.start(); // this should be super fast since the only non-stopped service is a NoOpService stoppingThread.join(1000); assertFalse("stopAsync has deadlocked!.", stoppingThread.isAlive()); failLeave.countDown(); // release the background thread }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 25.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
* * <p>This method should return promptly; prefer to do work on a different thread where it is * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is * called multiple times. * * <p>If {@link #stopAsync} is called on a {@link State#STARTING} service, this method is not * invoked immediately. Instead, it will be deferred until after the service is {@link
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
import java.util.concurrent.Executor; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; /** * An object with an operational state, plus asynchronous {@link #startAsync()} and {@link * #stopAsync()} lifecycle methods to transition between states. Example services include * webservers, RPC servers and timers. * * <p>The normal lifecycle of a service is: * * <ul> * <li>{@linkplain State#NEW NEW} ->
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
* * <p>This method should return promptly; prefer to do work on a different thread where it is * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is * called multiple times. * * <p>If {@link #stopAsync} is called on a {@link State#STARTING} service, this method is not * invoked immediately. Instead, it will be deferred until after the service is {@link
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
import java.util.concurrent.Executor; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; /** * An object with an operational state, plus asynchronous {@link #startAsync()} and {@link * #stopAsync()} lifecycle methods to transition between states. Example services include * webservers, RPC servers and timers. * * <p>The normal lifecycle of a service is: * * <ul> * <li>{@linkplain State#NEW NEW} ->
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
state.awaitHealthy(timeout, unit); } /** * Initiates service {@linkplain Service#stopAsync shutdown} if necessary on all the services * being managed. * * @return this */ @CanIgnoreReturnValue public ServiceManager stopAsync() { for (Service service : services) { service.stopAsync(); } return this; } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
state.awaitHealthy(timeout, unit); } /** * Initiates service {@linkplain Service#stopAsync shutdown} if necessary on all the services * being managed. * * @return this */ @CanIgnoreReturnValue public ServiceManager stopAsync() { for (Service service : services) { service.stopAsync(); } return this; } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
@Override public final Service startAsync() { delegate.startAsync(); return this; } /** @since 15.0 */ @CanIgnoreReturnValue @Override public final Service stopAsync() { delegate.stopAsync(); return this; } /** @since 15.0 */ @Override public final void awaitRunning() { delegate.awaitRunning(); } /** @since 28.0 */ @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 16:22:21 UTC 2024 - 27.8K bytes - Viewed (0)