Package ch.rswk.meta.engine

Class AbstractEngineExecutionThreadService<C>

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

ch.rswk.meta.engine.AbstractEngineExecutionThreadService<C>

All Implemented Interfaces:

EngineServices.ConfigurableService<C>, EngineServices.InfoProvidingService, com.google.common.util.concurrent.Service

Direct Known Subclasses:

AbstractEngineWorkQueueService, HttpService

public abstract class AbstractEngineExecutionThreadService<C>
extends com.google.common.util.concurrent.AbstractExecutionThreadService
implements EngineServices.ConfigurableService<C>, EngineServices.InfoProvidingService

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
private final Class<C>	configClass
private final AtomicReference<C>	configReference
private io.reactivex.rxjava3.disposables.Disposable	configWatcherSub
protected EngineRuntime	runtime

Constructor Summary

Constructors

Constructor	Description
AbstractEngineExecutionThreadService(C config, EngineRuntime runtime)

Method Summary

Modifier and Type	Method	Description
Class<C>	configClass()
AtomicReference<C>	configReference()
protected String	serviceName()
protected void	shutDown()
protected void	startUp()

Methods inherited from class com.google.common.util.concurrent.AbstractExecutionThreadService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, run, startAsync, state, stopAsync, toString, triggerShutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ch.rswk.meta.engine.EngineServices.ConfigurableService

config, onConfigChanged

Methods inherited from interface ch.rswk.meta.engine.EngineServices.InfoProvidingService

getServiceInfo

Field Details

configClass

private final Class<C> configClass

configReference

private final AtomicReference<C> configReference

runtime

protected EngineRuntime runtime

configWatcherSub

private io.reactivex.rxjava3.disposables.Disposable configWatcherSub

Constructor Details

AbstractEngineExecutionThreadService

public AbstractEngineExecutionThreadService(C config,
 EngineRuntime runtime)

Method Details

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class com.google.common.util.concurrent.AbstractExecutionThreadService

Throws:

Exception

shutDown

protected void shutDown()
                 throws Exception

Overrides:

shutDown in class com.google.common.util.concurrent.AbstractExecutionThreadService

Throws:

Exception

serviceName

protected String serviceName()

Overrides:

serviceName in class com.google.common.util.concurrent.AbstractExecutionThreadService

configClass

public Class<C> configClass()

Specified by:

configClass in interface EngineServices.ConfigurableService<C>

configReference

public AtomicReference<C> configReference()

Specified by:

configReference in interface EngineServices.ConfigurableService<C>