org.apache.spark.util

Class EventLoop<E>

Object

org.apache.spark.util.EventLoop<E>

All Implemented Interfaces:

Logging

Direct Known Subclasses:

DAGSchedulerEventProcessLoop

public abstract class EventLoop<E>
extends Object
implements Logging

An event loop to receive events from the caller and process all events in the event thread. It will start an exclusive event thread to process all events.

Note: The event queue will grow indefinitely. So subclasses should make sure onReceive can handle events in time to avoid the potential OOM.

Constructor Summary

Constructors

Constructor and Description
EventLoop(String name)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isActive() Return if the event thread has already been started but not yet stopped.
void	post(E event) Put the event into the event queue.
void	start()
void	stop()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

EventLoop

public EventLoop(String name)

Method Detail

start

public void start()

stop

public void stop()

post

public void post(E event)

Put the event into the event queue. The event thread will process it later.

isActive

public boolean isActive()

Return if the event thread has already been started but not yet stopped.