Package ch.rswk.meta.engine

Class AbstractEngineWorkQueueService<C,T,R>

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

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

ch.rswk.meta.engine.AbstractEngineWorkQueueService<C,T,R>

All Implemented Interfaces:

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

Direct Known Subclasses:

LuceneService

public abstract class AbstractEngineWorkQueueService<C,T,R>
extends AbstractEngineExecutionThreadService<C>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final record	AbstractEngineWorkQueueService.Wrapper<T,R>

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 static final org.slf4j.Logger	LOG
private static final AbstractEngineWorkQueueService.Wrapper<Object,Object>	POISON
private com.codahale.metrics.Meter	processErrorMeter
private final BlockingDeque<AbstractEngineWorkQueueService.Wrapper<T,R>>	queue
private static final Protocol.ErrorReplyFactory	WORK_QUEUE_ERROR
private static final Protocol.ErrorReplyFactory	WORK_UNIT_ERROR
private com.codahale.metrics.Timer	workUnitTimer

Fields inherited from class ch.rswk.meta.engine.AbstractEngineExecutionThreadService

runtime

Constructor Summary

Constructors

Constructor	Description
AbstractEngineWorkQueueService(C config, EngineRuntime runtime)

Method Summary

Modifier and Type	Method	Description
protected void	afterProcessWorkUnit(T unit)
protected void	beforeProcessWorkUnit(T unit)
protected boolean	isWorkQueueEmpty()
protected com.google.common.util.concurrent.ListenableFuture<R>	offerWorkUnit(T unit)
protected abstract R	processWorkUnit(T unit)
protected void	run()
protected void	startUp()
protected void	triggerShutdown()

Methods inherited from class ch.rswk.meta.engine.AbstractEngineExecutionThreadService

configClass, configReference, onConfigWatcherNotification, serviceId, serviceName, shutDown

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

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

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, handleConfigWatcherNotification, onConfigChanged

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

getServiceInfo

Field Details

LOG

private static final org.slf4j.Logger LOG

POISON

private static final AbstractEngineWorkQueueService.Wrapper<Object,Object> POISON

WORK_QUEUE_ERROR

private static final Protocol.ErrorReplyFactory WORK_QUEUE_ERROR

WORK_UNIT_ERROR

private static final Protocol.ErrorReplyFactory WORK_UNIT_ERROR

queue

private final BlockingDeque<AbstractEngineWorkQueueService.Wrapper<T,R>> queue

processErrorMeter

private com.codahale.metrics.Meter processErrorMeter

workUnitTimer

private com.codahale.metrics.Timer workUnitTimer

Constructor Details

AbstractEngineWorkQueueService

public AbstractEngineWorkQueueService(C config,
 EngineRuntime runtime)

Method Details

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class AbstractEngineExecutionThreadService<C>

Throws:

Exception

triggerShutdown

protected void triggerShutdown()

Overrides:

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

offerWorkUnit

protected com.google.common.util.concurrent.ListenableFuture<R> offerWorkUnit(T unit)

isWorkQueueEmpty

protected boolean isWorkQueueEmpty()

run

protected void run()
            throws Exception

Specified by:

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

Throws:

Exception

beforeProcessWorkUnit

protected void beforeProcessWorkUnit(T unit)

processWorkUnit

protected abstract R processWorkUnit(T unit)
                              throws ErrorReplyException

Throws:

ErrorReplyException

afterProcessWorkUnit

protected void afterProcessWorkUnit(T unit)