org.zeromq.api

Interface Reactor

All Known Implementing Classes:

ReactorImpl

public interface Reactor

An event-driven reactor.

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	start() Start the reactor.
void	stop() Stop the reactor.

Method Detail

start

void start()

Start the reactor.

stop

void stop()

Stop the reactor.

addPollable

void addPollable(Pollable pollable,
                 LoopHandler handler)

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.

Parameters:

pollable - The Pollable with the socket to poll

handler - The loop handler

addTimer

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

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.

Parameters:

initialDelay - The initial delay, in milliseconds

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

handler - The loop handler

cancel

void cancel(LoopHandler handler)

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.

Parameters:

handler - The loop handler