org.zeromq.jzmq.reactor

Class ReactorImpl

java.lang.Object

org.zeromq.jzmq.reactor.ReactorImpl

All Implemented Interfaces:

Runnable, Reactor

public class ReactorImpl
extends Object
implements Reactor, Runnable

Constructor Summary

Constructors

Constructor and Description
ReactorImpl(ManagedContext context)

Method Summary

Modifier and Type	Method and Description
void	addPollable(Pollable pollable, LoopHandler handler) Add a new Pollable to this Reactor.
void	addTimer(long initialDelay, int numIterations, LoopHandler handler) Add a new ReactorTimer to this Reactor.
void	cancel(LoopHandler handler) Cancel an existing Pollable or ReactorTimer and remove the corresponding LoopHandler from executing.
void	run()
void	start() Start the reactor.
void	stop() Stop the reactor.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactorImpl

public ReactorImpl(ManagedContext context)

Method Detail

addPollable

public void addPollable(Pollable pollable,
                        LoopHandler handler)

Description copied from interface: Reactor

Add a new Pollable to this Reactor.

This method is not thread-safe, and should only be done from inside the LoopHandler when invoked by the Reactor on its own thread.

Specified by:

addPollable in interface Reactor

Parameters:

pollable - The Pollable with the socket to poll

handler - The loop handler

addTimer

public void addTimer(long initialDelay,
                     int numIterations,
                     LoopHandler handler)

Description copied from interface: Reactor

Add a new ReactorTimer to this Reactor.

This method is not thread-safe, and should only be done from inside the LoopHandler when invoked by the Reactor on its own thread.

Specified by:

addTimer in interface Reactor

Parameters:

initialDelay - The initial delay, in milliseconds

numIterations - The number of iterations, after which this timer stop

handler - The loop handler

cancel

public void cancel(LoopHandler handler)

Description copied from interface: Reactor

Cancel an existing Pollable or ReactorTimer and remove the corresponding LoopHandler from executing.

This method is not thread-safe, and should only be done from inside the LoopHandler when invoked by the Reactor on its own thread.

Specified by:

cancel in interface Reactor

Parameters:

handler - The loop handler

start

public void start()

Description copied from interface: Reactor

Start the reactor.

Specified by:

start in interface Reactor

stop

public void stop()

Description copied from interface: Reactor

Stop the reactor.

Specified by:

stop in interface Reactor

run

public void run()

Specified by:

run in interface Runnable