public class NetworkConnectionScheduler extends Object
Constructor and Description |
---|
NetworkConnectionScheduler(String name,
int numberOfSelectors,
int threadPoolSize,
long threadKeepAliveTimeout) |
NetworkConnectionScheduler(String name,
int numberOfSelectors,
int threadPoolSize,
long threadKeepAliveTimeout,
ThreadFactory factory) |
Modifier and Type | Method and Description |
---|---|
void |
addAcceptingSocket(ServerSocketChannel serverSocket,
NonBlockingNetworkTransport nonBlockingNetworkTransport) |
void |
addConnection(NonBlockingConnection connection) |
void |
cancelAcceptingSocket(ServerSocketChannel serverSocket) |
void |
close() |
String |
getName() |
void |
removeConnection(NonBlockingConnection connection) |
void |
schedule(NonBlockingConnection connection) |
void |
start() |
String |
toString() |
public NetworkConnectionScheduler(String name, int numberOfSelectors, int threadPoolSize, long threadKeepAliveTimeout)
public NetworkConnectionScheduler(String name, int numberOfSelectors, int threadPoolSize, long threadKeepAliveTimeout, ThreadFactory factory)
public void start()
public void close()
public String getName()
public void addAcceptingSocket(ServerSocketChannel serverSocket, NonBlockingNetworkTransport nonBlockingNetworkTransport)
public void cancelAcceptingSocket(ServerSocketChannel serverSocket)
public void addConnection(NonBlockingConnection connection)
public void removeConnection(NonBlockingConnection connection)
public void schedule(NonBlockingConnection connection)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.