org.jppf.server.nio
Class ChannelSelectorThread

java.lang.Object
  org.jppf.utils.ThreadSynchronization
      org.jppf.server.nio.ChannelSelectorThread

All Implemented Interfaces:

Runnable

public class ChannelSelectorThread
extends ThreadSynchronization
implements Runnable

Instances of this class perform the selection loop for a local (in-VM) channel.

Author:

Laurent Cohen

Field Summary

Fields inherited from class org.jppf.utils.ThreadSynchronization

stopped

Constructor Summary

ChannelSelectorThread(ChannelSelector selector, NioServer<?,?> server)
Initialize this threadwith the specified name, selector and NIO server.

Method Summary

void	close() Closes this channel selector.
void	run() Perform the selection loop.

Methods inherited from class org.jppf.utils.ThreadSynchronization

goToSleep, goToSleep, goToSleep, isStopped, setStopped, wakeUp

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelSelectorThread

public ChannelSelectorThread(ChannelSelector selector,
                             NioServer<?,?> server)

Initialize this threadwith the specified name, selector and NIO server.

Parameters:

selector - the channel selector associated with this thread.

server - the nio server that own this thread.

Method Detail

run

public void run()

Perform the selection loop.

Specified by:

run in interface Runnable

See Also:

Runnable.run()

close

public void close()

Closes this channel selector. If close() was already called, then this method has no effect.