zmq

Class Poller

java.lang.Object

zmq.PollerBase

zmq.Poller

All Implemented Interfaces:

java.lang.Runnable

public class Poller
extends PollerBase
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	Poller.PollSet

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<java.nio.channels.SelectableChannel,Poller.PollSet>	fdTable
private java.lang.String	name
private java.util.concurrent.atomic.AtomicBoolean	retired
private java.nio.channels.Selector	selector
private boolean	stopped
private boolean	stopping
private java.lang.Thread	worker

Constructor Summary

Constructors

Constructor and Description
Poller()
Poller(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
void	addHandle(java.nio.channels.SelectableChannel fd, IPollEvents events)
void	destroy()
private void	rebuildSelector()
private void	register(java.nio.channels.SelectableChannel handle, int ops, boolean negate)
void	removeHandle(java.nio.channels.SelectableChannel handle)
void	resetPollOn(java.nio.channels.SelectableChannel handle)
void	resetPollOut(java.nio.channels.SelectableChannel handle)
void	run()
void	setPollAccept(java.nio.channels.SelectableChannel handle)
void	setPollConnect(java.nio.channels.SelectableChannel handle)
void	setPollIn(java.nio.channels.SelectableChannel handle)
void	setPollOut(java.nio.channels.SelectableChannel handle)
void	start()
void	stop()

Methods inherited from class zmq.PollerBase

addTimer, adjustLoad, cancelTimer, executeTimers, getLoad

Methods inherited from class java.lang.Object

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

Field Detail

fdTable

private final java.util.Map<java.nio.channels.SelectableChannel,Poller.PollSet> fdTable

retired

private final java.util.concurrent.atomic.AtomicBoolean retired

stopping

private volatile boolean stopping

stopped

private volatile boolean stopped

worker

private java.lang.Thread worker

selector

private java.nio.channels.Selector selector

name

private final java.lang.String name

Constructor Detail

Poller

public Poller()

Poller

public Poller(java.lang.String name)

Method Detail

destroy

public void destroy()

addHandle

public final void addHandle(java.nio.channels.SelectableChannel fd,
                            IPollEvents events)

removeHandle

public final void removeHandle(java.nio.channels.SelectableChannel handle)

setPollIn

public final void setPollIn(java.nio.channels.SelectableChannel handle)

resetPollOn

public final void resetPollOn(java.nio.channels.SelectableChannel handle)

setPollOut

public final void setPollOut(java.nio.channels.SelectableChannel handle)

resetPollOut

public final void resetPollOut(java.nio.channels.SelectableChannel handle)

setPollConnect

public final void setPollConnect(java.nio.channels.SelectableChannel handle)

setPollAccept

public final void setPollAccept(java.nio.channels.SelectableChannel handle)

register

private final void register(java.nio.channels.SelectableChannel handle,
                            int ops,
                            boolean negate)

start

public void start()

stop

public void stop()

run

public void run()

Specified by:

run in interface java.lang.Runnable

rebuildSelector

private void rebuildSelector()