public abstract class ExecutorOperationSupport<T extends ExecutorServiceProvider> extends Object
Modifier and Type | Field and Description |
---|---|
static Integer |
CALLBACKS |
static Integer |
EVENTS |
static Integer |
MESSAGES_INCOMING |
static Integer |
MESSAGES_OUTGOING |
Modifier | Constructor and Description |
---|---|
protected |
ExecutorOperationSupport(String queueName) |
Modifier and Type | Method and Description |
---|---|
protected void |
addedTask(Runnable r) |
void |
addIncomingTask(Runnable r) |
void |
addOperationListener(ExecutorOperationListener listener) |
void |
addOutgoingTask(Runnable r) |
void |
addTask(Integer queue,
Runnable r) |
void |
cleanupOperations() |
protected void |
completedTask(Runnable r) |
abstract T |
getContext() |
int |
getOperationsCount() |
void |
removeOperationListener(ExecutorOperationListener listener) |
protected void |
startTask(Runnable r) |
public static final Integer MESSAGES_INCOMING
public static final Integer MESSAGES_OUTGOING
public static final Integer EVENTS
public static final Integer CALLBACKS
protected ExecutorOperationSupport(String queueName)
public abstract T getContext()
public void addOperationListener(ExecutorOperationListener listener)
public void removeOperationListener(ExecutorOperationListener listener)
public void addOutgoingTask(Runnable r)
public void addIncomingTask(Runnable r)
public void cleanupOperations()
public int getOperationsCount()
protected void addedTask(Runnable r)
protected void startTask(Runnable r)
protected void completedTask(Runnable r)
Copyright © 2017. All rights reserved.