net.openhft.chronicle.core.threads

Class DelegatingEventLoop

java.lang.Object

net.openhft.chronicle.core.threads.DelegatingEventLoop

All Implemented Interfaces:

Closeable, AutoCloseable, QueryCloseable, EventLoop

public class DelegatingEventLoop
extends Object
implements EventLoop

Field Summary

Fields inherited from interface net.openhft.chronicle.core.threads.EventLoop

DEBUG_ADDING_HANDLERS

Constructor Summary

Constructors

Constructor and Description
DelegatingEventLoop(@NotNull EventLoop eventLoop)

Method Summary

Modifier and Type	Method and Description
void	addHandler(EventHandler handler) Add handler to event loop to be executed.
void	awaitTermination() Wait until the event loop has terminated (after EventLoop.stop() has been called)
void	close() Stop the event loop, then close any resources being held.
boolean	isAlive()
boolean	isClosed() Is this object closed
boolean	isClosing() Is this object closed, or in the process of closing
boolean	isStopped()
String	name()
void	start() Start the event loop
void	stop() Stop executing handlers and block until all handlers are complete.
void	unpause() Typical implementation will unpause the event loop's Pauser

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.openhft.chronicle.core.threads.EventLoop

inEventLoop

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

closeQuietly, closeQuietly

Constructor Detail

DelegatingEventLoop

public DelegatingEventLoop(@NotNull
                           @NotNull EventLoop eventLoop)

Method Detail

name

public String name()

Specified by:

name in interface EventLoop

start

public void start()

Description copied from interface: EventLoop

Start the event loop

Specified by:

start in interface EventLoop

unpause

public void unpause()

Description copied from interface: EventLoop

Typical implementation will unpause the event loop's Pauser

Specified by:

unpause in interface EventLoop

stop

public void stop()

Description copied from interface: EventLoop

Stop executing handlers and block until all handlers are complete.

It is not expected that event loops can then be restarted.

Specified by:

stop in interface EventLoop

isClosed

public boolean isClosed()

Description copied from interface: QueryCloseable

Is this object closed

Specified by:

isClosed in interface QueryCloseable

Returns:

true if close() has completed

isStopped

public boolean isStopped()

Specified by:

isStopped in interface EventLoop

Returns:

is it in the stopped state.

isClosing

public boolean isClosing()

Description copied from interface: QueryCloseable

Is this object closed, or in the process of closing

This should always be true if QueryCloseable.isClosed() is true

Specified by:

isClosing in interface QueryCloseable

Returns:

true if close() has been called (but not necessarily completed)

isAlive

public boolean isAlive()

Specified by:

isAlive in interface EventLoop

Returns:

true if the main thread is running

awaitTermination

public void awaitTermination()

Description copied from interface: EventLoop

Wait until the event loop has terminated (after EventLoop.stop() has been called)

Specified by:

awaitTermination in interface EventLoop

close

public void close()

Description copied from interface: EventLoop

Stop the event loop, then close any resources being held. Blocks until the handlers are all stopped and closed

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface EventLoop

addHandler

public void addHandler(EventHandler handler)

Description copied from interface: EventLoop

Add handler to event loop to be executed. Event loops should execute handlers in order of priority. Handlers with same priority have no guarantee of execution order. Handlers will not be executed before EventLoop.start() has been called.

Specified by:

addHandler in interface EventLoop

Parameters:

handler - handler