Package org.apache.hc.core5.testing.nio

Class IOReactorExecutor<T extends IOReactorService>

java.lang.Object

org.apache.hc.core5.testing.nio.IOReactorExecutor<T>

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

AsyncRequester, AsyncServer

abstract class IOReactorExecutor<T extends IOReactorService>
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	IOReactorExecutor.Status

Field Summary

Fields

Modifier and Type	Field	Description
private final IOReactorConfig	ioReactorConfig
private final AtomicReference<T>	ioReactorRef
private final AtomicReference<IOReactorExecutor.Status>	status
private final ThreadFactory	workerThreadFactory

Constructor Summary

Constructors

Constructor	Description
IOReactorExecutor(IOReactorConfig ioReactorConfig, ThreadFactory workerThreadFactory)

Method Summary

Modifier and Type	Method	Description
void	awaitShutdown(TimeValue waitTime)
void	close()
(package private) abstract T	createIOReactor(IOEventHandlerFactory ioEventHandlerFactory, IOReactorConfig ioReactorConfig, ThreadFactory threadFactory, Callback<IOSession> sessionShutdownCallback)
private T	ensureRunning()
protected void	execute(IOEventHandlerFactory ioEventHandlerFactory)
IOReactorStatus	getStatus()
void	initiateShutdown()
(package private) T	reactor()
void	shutdown(TimeValue graceTime)

Methods inherited from class java.lang.Object

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

Field Details

ioReactorConfig

private final IOReactorConfig ioReactorConfig

workerThreadFactory

private final ThreadFactory workerThreadFactory

ioReactorRef

private final AtomicReference<T extends IOReactorService> ioReactorRef

status

private final AtomicReference<IOReactorExecutor.Status> status

Constructor Details

IOReactorExecutor

IOReactorExecutor(IOReactorConfig ioReactorConfig,
 ThreadFactory workerThreadFactory)

Method Details

createIOReactor

abstract T createIOReactor(IOEventHandlerFactory ioEventHandlerFactory,
 IOReactorConfig ioReactorConfig,
 ThreadFactory threadFactory,
 Callback<IOSession> sessionShutdownCallback)
                    throws IOException

Throws:

IOException

execute

protected void execute(IOEventHandlerFactory ioEventHandlerFactory)
                throws IOException

Throws:

IOException

ensureRunning

private T ensureRunning()

reactor

T reactor()

getStatus

public IOReactorStatus getStatus()

awaitShutdown

public void awaitShutdown(TimeValue waitTime)
                   throws InterruptedException

Throws:

InterruptedException

initiateShutdown

public void initiateShutdown()

shutdown

public void shutdown(TimeValue graceTime)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception