Package org.jgroups.util

Class SubmitToThreadPool

java.lang.Object

org.jgroups.util.SubmitToThreadPool

All Implemented Interfaces:

MessageProcessingPolicy

Direct Known Subclasses:

MaxOneThreadPerSender

public class SubmitToThreadPool
extends java.lang.Object
implements MessageProcessingPolicy

Default message processing policy. Submits all received messages and batches to the thread pool

Since:

4.0

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	SubmitToThreadPool.BatchHandler
class	SubmitToThreadPool.SingleLoopbackHandler
protected class	SubmitToThreadPool.SingleMessageHandler
protected class	SubmitToThreadPool.SingleMessageHandlerWithClusterName

Field Summary

Fields

Modifier and Type	Field	Description
protected Log	log
protected TP	tp
protected short	tp_id

Constructor Summary

Constructors

Constructor	Description
SubmitToThreadPool()

Method Summary

Modifier and Type	Method	Description
void	init(TP transport)	Called after creation.
void	loopback(Message msg, boolean oob, boolean internal)	Process a message that was not received from the transport but from above (e.g.
void	process(Message msg, boolean oob, boolean internal)	Process a message received from the transport
void	process(MessageBatch batch, boolean oob, boolean internal)	Process a batch received from the transport
protected void	removeAndDispatchNonBundledMessages(MessageBatch oob_batch)	Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.stack.MessageProcessingPolicy

destroy, reset

Field Detail

tp

protected TP tp

tp_id

protected short tp_id

log

protected Log log

Constructor Detail

SubmitToThreadPool

public SubmitToThreadPool()

Method Detail

init

public void init(TP transport)

Description copied from interface: MessageProcessingPolicy

Called after creation. Implementations may want to cache the transport reference to get access to thread pools, message counters etc

Specified by:

init in interface MessageProcessingPolicy

loopback

public void loopback(Message msg,
                     boolean oob,
                     boolean internal)

Description copied from interface: MessageProcessingPolicy

Process a message that was not received from the transport but from above (e.g. the channel or a protocol), and needs to be looped back up because (1) the destination address is null (every multicast message is looped back) or (2) the destination address is the sender's address (unicast message to self).
A message that is looped back can bypass cluster name matching.

Specified by:

loopback in interface MessageProcessingPolicy

Parameters:

msg - the message to be looped back up the stack.

oob - true if the message is an OOB message

internal - true if the message is internal

process

public void process(Message msg,
                    boolean oob,
                    boolean internal)

Description copied from interface: MessageProcessingPolicy

Process a message received from the transport

Specified by:

process in interface MessageProcessingPolicy

Parameters:

msg - the message

oob - true if the message is an OOB message

internal - true if the message is internal

process

public void process(MessageBatch batch,
                    boolean oob,
                    boolean internal)

Description copied from interface: MessageProcessingPolicy

Process a batch received from the transport

Specified by:

process in interface MessageProcessingPolicy

Parameters:

batch - the batch

oob - true if the batch contains only OOB messages

internal - true if the batch contains only internal messages (or internal and OOB messages)

removeAndDispatchNonBundledMessages

protected void removeAndDispatchNonBundledMessages(MessageBatch oob_batch)

Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool. JGRP-1737