com.marketfactory.mfapi.enterprise.api.engine

Class ChannelWorker

java.lang.Object

com.marketfactory.mfapi.enterprise.api.engine.ChannelWorker

All Implemented Interfaces:

Worker

public class ChannelWorker
extends java.lang.Object
implements Worker

Uses a Selector to generate read, write, and connect events from registered Channels. The single selector manages multiple channels - as many as you want to read from with a single thread. Channel events are dispatched to the EventHandler provided in the register call.

Write events are only generated if a write command fails to write all the bytes to the socket. This should be a rare occurrence.

Constructor Summary

Constructors

Constructor and Description
ChannelWorker()

Method Summary

Modifier and Type	Method and Description
void	doWork()
void	notifyPendingWrite(java.nio.channels.SocketChannel channel)
void	register(java.nio.channels.SocketChannel channel, EventHandler eventHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelWorker

public ChannelWorker()

Method Detail

register

public void register(java.nio.channels.SocketChannel channel,
                     EventHandler eventHandler)

notifyPendingWrite

public void notifyPendingWrite(java.nio.channels.SocketChannel channel)

doWork

public void doWork()

Specified by:

doWork in interface Worker