com.neeve.event

Class EventMultiplexerSingleThreaded

java.lang.Object

com.neeve.root.RootObject

com.neeve.event.EventObject

com.neeve.event.EventMultiplexer

com.neeve.event.EventMultiplexerSingleThreaded

All Implemented Interfaces:

IEventHandler, IEventMultiplexer

public final class EventMultiplexerSingleThreaded
extends EventMultiplexer

Single threaded event multiplexer.

In a single threaded event multiplexer, all events are dispatched by a single same thread i.e. the source threads handoff their events to the single dispatcher thread (via the multiplexer event queue) for onward dispatch.

Threading:

This class is safe for concurrent access by multiple threads.

Nested Class Summary

Nested classes/interfaces inherited from interface com.neeve.event.IEventMultiplexer

IEventMultiplexer.State

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROP_QUEUE_DEPTH Property used to configure the queue depth Property Name: "queueDepth" Default value: 1024
static int	PROP_QUEUE_DEPTH_DEFAULT The default value for PROP_QUEUE_DEPTH ("queueDepth"): 1024.
static String	PROP_QUEUE_DRAINER_CPU_AFFINITY_MASK Property used to configure the queue drainer CPU affinity mask Property Name: "queueDrainerCpuAffinityMask" Default value: UtlThread.getDefaultCPUAffinityMask()
static String	PROP_QUEUE_MAX_FEEDER_CONCURRENCY Property used to configure the queue max feeder concurrency Property Name: "queueFeedMaxConcurrency" Default value: 16
static int	PROP_QUEUE_MAX_FEEDER_CONCURRENCY_DEFAULT The default value for PROP_QUEUE_MAX_FEEDER_CONCURRENCY ("queueFeedMaxConcurrency"): 16.
static String	PROP_QUEUE_OFFER_STRATEGY Property used to configure the queue offer strategy Property Name: "queueOfferStrategy" Default value: "MultiThreaded"
static String	PROP_QUEUE_OFFER_STRATEGY_DEFAULT The default value for PROP_QUEUE_OFFER_STRATEGY ("queueOfferStrategy"): "MultiThreaded".
static String	PROP_QUEUE_WAIT_STRATEGY Property used to configure the queue wait strategy Property Name: "queueWaitStrategy" Default value:
static String	PROP_QUEUE_WAIT_STRATEGY_DEFAULT The default value for PROP_QUEUE_WAIT_STRATEGY ("queueWaitStrategy"): .

Fields inherited from class com.neeve.event.EventMultiplexer

recordEventLegLatencies

Fields inherited from interface com.neeve.event.IEventMultiplexer

NON_BLOCKING

Method Summary

Modifier and Type	Method and Description
static IEventMultiplexer	create(String name, boolean administrative, IEventHandler eventHandler, Properties props) Create a single threaded event multiplexer.
static IEventMultiplexer	create(String name, IEventHandler eventHandler, Properties props) Create a single threaded event multiplexer.
IEventMultiplexerStats	getStats() Implementation of IEventMultiplexer.getStats()

Methods inherited from class com.neeve.event.EventMultiplexer

close, getName, multiplexEvent, onEvent, onEvent, open, scheduledEventCount, scheduleEvent, setAllEventDispatch, unscheduleEvent

Methods inherited from class com.neeve.root.RootObject

getChecked, getThreaded, getTracer

Methods inherited from class java.lang.Object

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

Field Detail

PROP_QUEUE_DEPTH

public static final String PROP_QUEUE_DEPTH

Property used to configure the queue depth

Property Name: "queueDepth"
Default value: 1024

See Also:

Constant Field Values

PROP_QUEUE_DEPTH_DEFAULT

public static final int PROP_QUEUE_DEPTH_DEFAULT

The default value for PROP_QUEUE_DEPTH ("queueDepth"): 1024.

See Also:

Constant Field Values

PROP_QUEUE_OFFER_STRATEGY

public static final String PROP_QUEUE_OFFER_STRATEGY

Property used to configure the queue offer strategy

Property Name: "queueOfferStrategy"
Default value: "MultiThreaded"

See Also:

Constant Field Values

PROP_QUEUE_OFFER_STRATEGY_DEFAULT

public static final String PROP_QUEUE_OFFER_STRATEGY_DEFAULT

The default value for PROP_QUEUE_OFFER_STRATEGY ("queueOfferStrategy"): "MultiThreaded".

See Also:

Constant Field Values

PROP_QUEUE_WAIT_STRATEGY

public static final String PROP_QUEUE_WAIT_STRATEGY

Property used to configure the queue wait strategy

Property Name: "queueWaitStrategy"
Default value:

See Also:

Constant Field Values

PROP_QUEUE_WAIT_STRATEGY_DEFAULT

public static final String PROP_QUEUE_WAIT_STRATEGY_DEFAULT

The default value for PROP_QUEUE_WAIT_STRATEGY ("queueWaitStrategy"): .

A default value of null means that the default is resolved by UtlDisruptor.getWaitStrategy(java.lang.String, boolean)

PROP_QUEUE_MAX_FEEDER_CONCURRENCY

public static final String PROP_QUEUE_MAX_FEEDER_CONCURRENCY

Property used to configure the queue max feeder concurrency

Property Name: "queueFeedMaxConcurrency"
Default value: 16

See Also:

Constant Field Values

PROP_QUEUE_MAX_FEEDER_CONCURRENCY_DEFAULT

public static final int PROP_QUEUE_MAX_FEEDER_CONCURRENCY_DEFAULT

The default value for PROP_QUEUE_MAX_FEEDER_CONCURRENCY ("queueFeedMaxConcurrency"): 16.

See Also:

Constant Field Values

PROP_QUEUE_DRAINER_CPU_AFFINITY_MASK

public static final String PROP_QUEUE_DRAINER_CPU_AFFINITY_MASK

Property used to configure the queue drainer CPU affinity mask

Property Name: "queueDrainerCpuAffinityMask"
Default value: UtlThread.getDefaultCPUAffinityMask()

See Also:

Constant Field Values

Method Detail

create

public static final IEventMultiplexer create(String name,
                                             boolean administrative,
                                             IEventHandler eventHandler,
                                             Properties props)

Create a single threaded event multiplexer.

Parameters:

name - The event multiplexer's name

administrative - Whether this multiplexer is an administrative one i.e. not subject to auto performance tuning.

eventHandler - The dispatch event handler i.e. the event handler through which multiplexed events are dispatched.

props - A set of properties that qualify the behavior multiplexer behavior. See the constructor documentation for the set of properties supported by a sungle threaded event multiplexer.

create

public static final IEventMultiplexer create(String name,
                                             IEventHandler eventHandler,
                                             Properties props)

Create a single threaded event multiplexer.

This method invokes create(name, false, eventHandler, props)

getStats

public final IEventMultiplexerStats getStats()

Implementation of IEventMultiplexer.getStats()