io.engineblock.activities.diag

Class AsyncDiagAction

java.lang.Object

io.engineblock.activityapi.core.BaseAsyncAction<OpContext,DiagActivity>

io.engineblock.activities.diag.AsyncDiagAction

All Implemented Interfaces:

Action, ActivityDefObserver, AsyncAction<OpContext>, Stoppable

public class AsyncDiagAction
extends BaseAsyncAction<OpContext,DiagActivity>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncDiagAction.DiagOpContext

Field Summary

Fields inherited from class io.engineblock.activityapi.core.BaseAsyncAction

activity, pendingOpsCounter, running, slot

Constructor Summary

Constructors

Constructor and Description
AsyncDiagAction(DiagActivity activity, int slot)

Method Summary

Modifier and Type	Method and Description
boolean	awaitCompletion(long timeout)
boolean	enqueue(OpContext opc)
AsyncDiagAction.DiagOpContext	newOpContext()
void	onActivityDefUpdate(ActivityDef activityDef)
protected OpContext	startOpCycle(OpContext opc)

Methods inherited from class io.engineblock.activityapi.core.BaseAsyncAction

available, decrementOps, getMaxPendingOps, incrementOps, pending, requestStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.engineblock.activityapi.core.Action

init

Constructor Detail

AsyncDiagAction

public AsyncDiagAction(DiagActivity activity,
                       int slot)

Method Detail

onActivityDefUpdate

public void onActivityDefUpdate(ActivityDef activityDef)

Specified by:

onActivityDefUpdate in interface ActivityDefObserver

Overrides:

onActivityDefUpdate in class BaseAsyncAction<OpContext,DiagActivity>

enqueue

public boolean enqueue(OpContext opc)

Specified by:

enqueue in interface AsyncAction<OpContext>

Overrides:

enqueue in class BaseAsyncAction<OpContext,DiagActivity>

startOpCycle

protected OpContext startOpCycle(OpContext opc)

Specified by:

startOpCycle in class BaseAsyncAction<OpContext,DiagActivity>

awaitCompletion

public boolean awaitCompletion(long timeout)

Specified by:

awaitCompletion in interface AsyncAction<OpContext>

Overrides:

awaitCompletion in class BaseAsyncAction<OpContext,DiagActivity>

newOpContext

public AsyncDiagAction.DiagOpContext newOpContext()

Specified by:

newOpContext in interface AsyncAction<OpContext>

Specified by:

newOpContext in class BaseAsyncAction<OpContext,DiagActivity>