Package | Description |
---|---|
org.ice4j.stack |
Modifier and Type | Field and Description |
---|---|
private ConcurrentHashMap.KeySetView<MessageProcessingTask,Boolean> |
NetAccessManager.activeTasks
The set of
MessageProcessingTask 's which are not yet finished
it's, processing, tracking of active tasks is necessary to properly
cancel pending tasks in case NetAccessManager.stop() is called. |
private Consumer<MessageProcessingTask> |
NetAccessManager.onRawMessageProcessed
Callback to be called when scheduled MessageProcessingTask
completes processing it's RawMessage.
|
private Consumer<MessageProcessingTask> |
MessageProcessingTask.rawMessageProcessedHandler
Callback which is invoked when this MessageProcessingTask
processed it's
rawMessage |
private ArrayBlockingQueue<MessageProcessingTask> |
NetAccessManager.taskPool
Pool of MessageProcessingTask objects to avoid extra-allocations
of processor object per RawMessage needed to process.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
MessageProcessingTask.setMessage(RawMessage message,
Consumer<MessageProcessingTask> onProcessed)
Assigns the RawMessage that will be processed
by this MessageProcessingTask on executor's thread.
|
Copyright © 2018. All rights reserved.