Class AbstractService
- java.lang.Object
- 
- com.google.common.util.concurrent.AbstractService
 
- 
- All Implemented Interfaces:
- Service
 
 @GwtIncompatible public abstract class AbstractService extends Object implements Service Base class for implementing services that can handledoStart()anddoStop()requests, responding to them withnotifyStarted()andnotifyStopped()callbacks. Its subclasses must manage threads manually; considerAbstractExecutionThreadServiceif you need only a single execution thread.- Since:
- 1.0
- Author:
- Jesse Wilson, Luke Sandberg
 
- 
- 
Nested Class Summary- 
Nested classes/interfaces inherited from interface com.google.common.util.concurrent.ServiceService.Listener, Service.State
 
- 
 - 
Constructor SummaryConstructors Modifier Constructor Description protectedAbstractService()Constructor for use by subclasses.
 - 
Method SummaryAll Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidaddListener(Service.Listener listener, Executor executor)Registers aService.Listenerto be executed on the given executor.voidawaitRunning()Waits for theServiceto reach the running state.voidawaitRunning(long timeout, TimeUnit unit)Waits for theServiceto reach the running state for no more than the given time.voidawaitTerminated()Waits for theServiceto reach the terminated state.voidawaitTerminated(long timeout, TimeUnit unit)Waits for theServiceto reach a terminal state (eitherterminatedorfailed) for no more than the given time.protected voiddoCancelStart()This method is called bystopAsync()when the service is still starting (i.e.protected abstract voiddoStart()This method is called bystartAsync()to initiate service startup.protected abstract voiddoStop()This method should be used to initiate service shutdown.ThrowablefailureCause()Returns theThrowablethat caused this service to fail.booleanisRunning()Returnstrueif this service is running.protected voidnotifyFailed(Throwable cause)Invoke this method to transition the service to theService.State.FAILED.protected voidnotifyStarted()Implementing classes should invoke this method once their service has started.protected voidnotifyStopped()Implementing classes should invoke this method once their service has stopped.ServicestartAsync()If the service state isService.State.NEW, this initiates service startup and returns immediately.Service.Statestate()Returns the lifecycle state of the service.ServicestopAsync()StringtoString()Returns a string representation of the object.
 
- 
- 
- 
Constructor Detail- 
AbstractServiceprotected AbstractService() Constructor for use by subclasses.
 
- 
 - 
Method Detail- 
doStart@ForOverride protected abstract void doStart() This method is called bystartAsync()to initiate service startup. The invocation of this method should cause a call tonotifyStarted(), either during this method's run, or after it has returned. If startup fails, the invocation should cause a call tonotifyFailed(Throwable)instead.This method should return promptly; prefer to do work on a different thread where it is convenient. It is invoked exactly once on service startup, even when startAsync()is called multiple times.
 - 
doStop@ForOverride protected abstract void doStop() This method should be used to initiate service shutdown. The invocation of this method should cause a call tonotifyStopped(), either during this method's run, or after it has returned. If shutdown fails, the invocation should cause a call tonotifyFailed(Throwable)instead.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 stopAsync()is called multiple times.If stopAsync()is called on aService.State.STARTINGservice, this method is not invoked immediately. Instead, it will be deferred until after the service isService.State.RUNNING. Services that need to cancel startup work can overridedoCancelStart().
 - 
doCancelStart@Beta @ForOverride protected void doCancelStart() This method is called bystopAsync()when the service is still starting (i.e.startAsync()has been called butnotifyStarted()has not). Subclasses can override the method to cancel pending work and then callnotifyStopped()to stop the service.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 stopAsync()is called multiple times.When this method is called state()will returnService.State.STOPPING, which is the external state observable by the caller ofstopAsync().- Since:
- 27.0
 
 - 
startAsync@CanIgnoreReturnValue public final Service startAsync() Description copied from interface:ServiceIf the service state isService.State.NEW, this initiates service startup and returns immediately. A stopped service may not be restarted.- Specified by:
- startAsyncin interface- Service
- Returns:
- this
 
 - 
stopAsync@CanIgnoreReturnValue public final Service stopAsync() Description copied from interface:ServiceIf the service is starting or running, this initiates service shutdown and returns immediately. If the service is new, it is terminated without having been started nor stopped. If the service has already been stopped, this method returns immediately without taking action.
 - 
awaitRunningpublic final void awaitRunning() Description copied from interface:ServiceWaits for theServiceto reach the running state.- Specified by:
- awaitRunningin interface- Service
 
 - 
awaitRunningpublic final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException Description copied from interface:ServiceWaits for theServiceto reach the running state for no more than the given time.- Specified by:
- awaitRunningin interface- Service
- Parameters:
- timeout- the maximum time to wait
- unit- the time unit of the timeout argument
- Throws:
- TimeoutException- if the service has not reached the given state within the deadline
 
 - 
awaitTerminatedpublic final void awaitTerminated() Description copied from interface:ServiceWaits for theServiceto reach the terminated state.- Specified by:
- awaitTerminatedin interface- Service
 
 - 
awaitTerminatedpublic final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException Description copied from interface:ServiceWaits for theServiceto reach a terminal state (eitherterminatedorfailed) for no more than the given time.- Specified by:
- awaitTerminatedin interface- Service
- Parameters:
- timeout- the maximum time to wait
- unit- the time unit of the timeout argument
- Throws:
- TimeoutException- if the service has not reached the given state within the deadline
 
 - 
notifyStartedprotected final void notifyStarted() Implementing classes should invoke this method once their service has started. It will cause the service to transition fromService.State.STARTINGtoService.State.RUNNING.- Throws:
- IllegalStateException- if the service is not- Service.State.STARTING.
 
 - 
notifyStoppedprotected final void notifyStopped() Implementing classes should invoke this method once their service has stopped. It will cause the service to transition fromService.State.STARTINGorService.State.STOPPINGtoService.State.TERMINATED.- Throws:
- IllegalStateException- if the service is not one of- Service.State.STOPPING,- Service.State.STARTING, or- Service.State.RUNNING.
 
 - 
notifyFailedprotected final void notifyFailed(Throwable cause) Invoke this method to transition the service to theService.State.FAILED. The service will not be stopped if it is running. Invoke this method when a service has failed critically or otherwise cannot be started nor stopped.
 - 
isRunningpublic final boolean isRunning() Description copied from interface:ServiceReturnstrueif this service is running.
 - 
statepublic final Service.State state() Description copied from interface:ServiceReturns the lifecycle state of the service.
 - 
failureCausepublic final Throwable failureCause() Description copied from interface:ServiceReturns theThrowablethat caused this service to fail.- Specified by:
- failureCausein interface- Service
- Since:
- 14.0
 
 - 
addListenerpublic final void addListener(Service.Listener listener, Executor executor) Description copied from interface:ServiceRegisters aService.Listenerto be executed on the given executor. The listener will have the corresponding transition method called whenever the service changes state. The listener will not have previous state changes replayed, so it is suggested that listeners are added before the service starts.addListenerguarantees execution ordering across calls to a given listener but not across calls to multiple listeners. Specifically, a given listener will have its callbacks invoked in the same order as the underlying service enters those states. Additionally, at most one of the listener's callbacks will execute at once. However, multiple listeners' callbacks may execute concurrently, and listeners may execute in an order different from the one in which they were registered.RuntimeExceptions thrown by a listener will be caught and logged. Any exception thrown during Executor.execute(e.g., aRejectedExecutionException) will be caught and logged.- Specified by:
- addListenerin interface- Service
- Parameters:
- listener- the listener to run when the service changes state is complete
- executor- the executor in which the listeners callback methods will be run. For fast, lightweight listeners that would be safe to execute in any thread, consider- MoreExecutors.directExecutor().
- Since:
- 13.0
 
 - 
toStringpublic String toString() Description copied from class:java.lang.ObjectReturns a string representation of the object. In general, thetoStringmethod returns a string that "textually represents" this object. The result should be a concise but informative representation that is easy for a person to read. It is recommended that all subclasses override this method.The toStringmethod for classObjectreturns a string consisting of the name of the class of which the object is an instance, the at-sign character `@', and the unsigned hexadecimal representation of the hash code of the object. In other words, this method returns a string equal to the value of:getClass().getName() + '@' + Integer.toHexString(hashCode()) 
 
- 
 
-