|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.opcfoundation.ua.utils.asyncsocket.AsyncSelector
public class AsyncSelector
Create asyncronous selector. Selector has one selector thread for each cpu core in the system. SelectionKeys are listened with register method.
To close async selector, close its selector (getSelector().close()).
AsyncSelector guarantees that selection event of a key is handled in one thread at a time, and it the event handled accordingly, new selection events do not occur.
| Nested Class Summary | |
|---|---|
static interface |
AsyncSelector.SelectListener
|
| Constructor Summary | |
|---|---|
AsyncSelector()
Construct AsyncSelector with brand new selector |
|
AsyncSelector(Selector sel)
Construct new AsyncSelector |
|
| Method Summary | |
|---|---|
void |
close()
close. |
Selector |
getSelector()
getSelector. |
void |
interestOps(SelectableChannel channel,
int interestOps)
Modify interest ops of a key. |
void |
register(SelectableChannel channel,
int ops,
AsyncSelector.SelectListener selectEventListener)
Register a selection event handler to a selectable channel. |
void |
run()
|
void |
unregister(SelectableChannel channel)
unregister. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public AsyncSelector()
throws IOException
IOException - if any.
public AsyncSelector(Selector sel)
throws IOException
sel - a Selector object.
IOException - if any.| Method Detail |
|---|
public Selector getSelector()
getSelector.
Selector object.
public void interestOps(SelectableChannel channel,
int interestOps)
throws CancelledKeyException
channel - registered keyinterestOps - new interest op set
CancelledKeyException - if any.
public void register(SelectableChannel channel,
int ops,
AsyncSelector.SelectListener selectEventListener)
throws ClosedChannelException
selectEventListener is invoked by one thread at a time. The rule of thumb is that the listener must not block. Note! If channel is registered and closed, select event is invoked until the channel is unregistered.
channel - a SelectableChannel object.ops - initial interest ops See SelectionKeyselectEventListener - a AsyncSelector.SelectListener object.
ClosedChannelException - if any.public void unregister(SelectableChannel channel)
unregister.
channel - a SelectableChannel object.
public void close()
throws IOException
close.
IOException - if any.public void run()
run in interface Runnable
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||