Class DedicatedExecutorProtocolHolder

java.lang.Object

pt.unl.fct.di.novasys.babel2.core.AbstractBabelProtocolHolder

pt.unl.fct.di.novasys.babel2.core.DedicatedExecutorProtocolHolder

All Implemented Interfaces:

BabelProtocolHolder

public final class DedicatedExecutorProtocolHolder
extends AbstractBabelProtocolHolder

A BabelProtocolHolder implementation that runs the protocol on a dedicated, single-threaded executor using a lock-free MpscArrayQueue.

This holder provides isolated execution for CPU-intensive protocols or protocols that must not share execution threads with others.

Field Summary

Fields inherited from class AbstractBabelProtocolHolder

protocol

Modifier and Type	Field	Description
protected final BabelProtocol	protocol	The managed protocol instance.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DedicatedExecutorProtocolHolder(BabelProtocol protocol, Set<ProtocolExtension<? extends BabelProtocol>> extensions, ExecutorService executor, int maxQueueCapacity)	Constructs a holder with a dedicated executor and bounded event queue.

Method Summary

Modifier and Type	Method	Description
void	deliverEvent(BabelEvent event)	Enqueues or delivers an event to the underlying protocol.

Methods inherited from class AbstractBabelProtocolHolder

createHandler, eventHandlers, getInnerProtocol, holdsProtocol, interestedEvents, interestedInMessages, interestedOutFailedMessages, interestedOutSuccessMessages, invokeHandler, invokeHandler, invokeHandler, invokeHandler

Modifier and Type	Method	Description
<T> T	createHandler(Method method, MethodHandles.Lookup lookup, Class<? extends BabelProtocol> protocolClass, Class<T> handlerInterface, String handlerMethodName, Class<?>[] erasedParamType, Class<?>[] actualParamType)	Creates a typed functional-interface handler for the given method using LambdaMetafactory.
Map<Class<? extends ProtocolEvent>, EventHandler<? extends ProtocolEvent>>	eventHandlers()	Returns the mapping of handled ProtocolEvent classes to their compiled event handlers.
BabelProtocol	getInnerProtocol()	Returns the underlying protocol instance managed by this holder.
boolean	holdsProtocol(Class<? extends BabelProtocol> protocolClass)	Returns whether this holder manages a protocol that is an instance of or assignable to the given protocol class.
Set<Class<? extends ProtocolEvent>>	interestedEvents()	Returns the set of ProtocolEvent classes that this protocol has registered interest in.
Set<Class<? extends BabelMessage>>	interestedInMessages()	Returns the set of BabelMessage classes that this protocol is interested in receiving.
Set<Class<? extends BabelMessage>>	interestedOutFailedMessages()	Returns the set of BabelMessage classes for which this protocol handles delivery failure.
Set<Class<? extends BabelMessage>>	interestedOutSuccessMessages()	Returns the set of BabelMessage classes for which this protocol handles successful delivery.
protected void	invokeHandler(MessageInEvent event)	Invokes the compiled handler for the specified inbound message event.
protected void	invokeHandler(MessageOutFailedEvent event)	Invokes the compiled handler for the specified outbound message failure event.
protected void	invokeHandler(MessageOutSuccessEvent event)	Invokes the compiled handler for the specified outbound message success event.
protected void	invokeHandler(ProtocolEvent event)	Invokes the compiled handler for the specified protocol event.

Methods inherited from class Object

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

Constructor Details

DedicatedExecutorProtocolHolder

protected DedicatedExecutorProtocolHolder(BabelProtocol protocol,
 Set<ProtocolExtension<? extends BabelProtocol>> extensions,
 ExecutorService executor,
 int maxQueueCapacity)

Constructs a holder with a dedicated executor and bounded event queue.

Parameters:

protocol - the protocol instance to manage

extensions - the protocol extensions configured for this protocol

executor - the dedicated executor service for this protocol

maxQueueCapacity - the maximum number of pending events allowed in the queue

Method Details

deliverEvent

public void deliverEvent(BabelEvent event)

Description copied from interface: BabelProtocolHolder

Enqueues or delivers an event to the underlying protocol.

Parameters:

event - the event to deliver