Class PollerBase

java.lang.Object

zmq.poll.PollerBase

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

Poller

abstract class PollerBase
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	PollerBase.TimerInfo

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	changed
private final AtomicInteger	load
private final MultiMap<Long, PollerBase.TimerInfo>	timers
protected final Thread	worker

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PollerBase(String name)

Method Summary

Modifier and Type	Method	Description
void	addTimer(long timeout, IPollEvents sink, int id)
protected void	adjustLoad(int amount)
void	cancelTimer(IPollEvents sink, int id)
(package private) long	clock()
(package private) Thread	createWorker(String name)
protected long	executeTimers()
final int	getLoad()
(package private) final boolean	isEmpty()

Methods inherited from class Object

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

Methods inherited from interface Runnable

run

Field Details

load

private final AtomicInteger load

timers

private final MultiMap<Long, PollerBase.TimerInfo> timers

worker

protected final Thread worker

changed

private boolean changed

Constructor Details

PollerBase

protected PollerBase(String name)

Method Details

createWorker

Thread createWorker(String name)

clock

long clock()

isEmpty

final boolean isEmpty()

getLoad

public final int getLoad()

adjustLoad

protected void adjustLoad(int amount)

addTimer

public void addTimer(long timeout,
 IPollEvents sink,
 int id)

cancelTimer

public void cancelTimer(IPollEvents sink,
 int id)

executeTimers

protected long executeTimers()