org.apache.http.impl.nio.reactor
Class AbstractMultiworkerIOReactor

java.lang.Object
  extended by org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor
All Implemented Interfaces:
IOReactor
Direct Known Subclasses:
DefaultConnectingIOReactor, DefaultListeningIOReactor

public abstract class AbstractMultiworkerIOReactor
extends java.lang.Object
implements IOReactor


Constructor Summary
AbstractMultiworkerIOReactor(long selectTimeout, int workerCount, ThreadFactory threadFactory)
           
 
Method Summary
protected  void addChannel(ChannelEntry entry)
           
protected  long getSelectTimeout()
           
protected  void startWorkers(IOEventDispatch eventDispatch)
           
protected  void stopWorkers(int millis)
           
protected  void verifyWorkers()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.http.nio.reactor.IOReactor
execute, shutdown
 

Constructor Detail

AbstractMultiworkerIOReactor

public AbstractMultiworkerIOReactor(long selectTimeout,
                                    int workerCount,
                                    ThreadFactory threadFactory)
                             throws IOReactorException
Throws:
IOReactorException
Method Detail

getSelectTimeout

protected long getSelectTimeout()

startWorkers

protected void startWorkers(IOEventDispatch eventDispatch)

stopWorkers

protected void stopWorkers(int millis)
                    throws java.io.InterruptedIOException,
                           IOReactorException
Throws:
java.io.InterruptedIOException
IOReactorException

verifyWorkers

protected void verifyWorkers()
                      throws java.io.InterruptedIOException,
                             IOReactorException
Throws:
java.io.InterruptedIOException
IOReactorException

addChannel

protected void addChannel(ChannelEntry entry)


Copyright © 2005-2009 Apache Software Foundation. All Rights Reserved.