Class SharedExecutorProtocolHolder

java.lang.Object

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

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

All Implemented Interfaces:

BabelProtocolHolder

public final class SharedExecutorProtocolHolder
extends AbstractBabelProtocolHolder

A BabelProtocolHolder implementation that schedules event queue draining on a shared thread pool executor.

Multiple protocols can share the same executor, with each protocol maintaining its own lock-free MpscArrayQueue. Protocols cooperate by yielding execution after processing a configurable number of events per turn (batch size), preventing starvation.

Field Summary

Fields inherited from class AbstractBabelProtocolHolder

protocol

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

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

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