org.apache.http.impl.nio.reactor
Class AbstractMultiworkerIOReactor
java.lang.Object
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(int workerCount,
java.util.concurrent.ThreadFactory threadFactory,
org.apache.http.params.HttpParams params)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
status
protected volatile IOReactorStatus status
params
protected final org.apache.http.params.HttpParams params
selector
protected final java.nio.channels.Selector selector
selectTimeout
protected final long selectTimeout
exceptionHandler
protected IOReactorExceptionHandler exceptionHandler
AbstractMultiworkerIOReactor
public AbstractMultiworkerIOReactor(int workerCount,
java.util.concurrent.ThreadFactory threadFactory,
org.apache.http.params.HttpParams params)
throws IOReactorException
- Throws:
IOReactorException
getStatus
public IOReactorStatus getStatus()
- Specified by:
getStatus
in interface IOReactor
setExceptionHandler
public void setExceptionHandler(IOReactorExceptionHandler exceptionHandler)
processEvents
protected abstract void processEvents(int count)
throws IOReactorException
- Throws:
IOReactorException
cancelRequests
protected abstract void cancelRequests()
throws IOReactorException
- Throws:
IOReactorException
execute
public void execute(IOEventDispatch eventDispatch)
throws java.io.InterruptedIOException,
IOReactorException
- Specified by:
execute
in interface IOReactor
- Throws:
java.io.InterruptedIOException
IOReactorException
doShutdown
protected void doShutdown()
throws java.io.IOException
- Throws:
java.io.IOException
addChannel
protected void addChannel(ChannelEntry entry)
registerChannel
protected java.nio.channels.SelectionKey registerChannel(java.nio.channels.SelectableChannel channel,
int ops)
throws java.nio.channels.ClosedChannelException
- Throws:
java.nio.channels.ClosedChannelException
prepareSocket
protected void prepareSocket(java.net.Socket socket)
throws java.io.IOException
- Throws:
java.io.IOException
awaitShutdown
protected void awaitShutdown(long timeout)
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
shutdown
public void shutdown()
throws java.io.IOException
- Specified by:
shutdown
in interface IOReactor
- Throws:
java.io.IOException
shutdown
public void shutdown(long waitMs)
throws java.io.IOException
- Specified by:
shutdown
in interface IOReactor
- Throws:
java.io.IOException
Copyright © 2005-2008 Apache Software Foundation. All Rights Reserved.