org.spf4j.io.tcp

Class TcpServer.TcpServerGuavaService

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.spf4j.io.tcp.TcpServer.TcpServerGuavaService

All Implemented Interfaces:

com.google.common.util.concurrent.Service, Closeable, AutoCloseable

Enclosing class:

TcpServer

public static final class TcpServer.TcpServerGuavaService
extends com.google.common.util.concurrent.AbstractExecutionThreadService
implements Closeable

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
TcpServerGuavaService(ExecutorService executor, ClientHandler handlerFactory, int serverPort, int acceptBacklog, int bindTimeoutMillis)

Method Summary

Modifier and Type	Method and Description
void	close()
protected Executor	executor()
void	run()
protected String	serviceName()
protected void	startUp()
String	toString()
protected void	triggerShutdown()

Methods inherited from class com.google.common.util.concurrent.AbstractExecutionThreadService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, shutDown, startAsync, state, stopAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpServerGuavaService

public TcpServerGuavaService(ExecutorService executor,
                             ClientHandler handlerFactory,
                             int serverPort,
                             int acceptBacklog,
                             int bindTimeoutMillis)

Method Detail

startUp

protected void startUp()
                throws Exception

Overrides:

startUp in class com.google.common.util.concurrent.AbstractExecutionThreadService

Throws:

Exception

run

public void run()
         throws IOException

Specified by:

run in class com.google.common.util.concurrent.AbstractExecutionThreadService

Throws:

IOException

executor

protected Executor executor()

Overrides:

executor in class com.google.common.util.concurrent.AbstractExecutionThreadService

serviceName

protected String serviceName()

Overrides:

serviceName in class com.google.common.util.concurrent.AbstractExecutionThreadService

triggerShutdown

protected void triggerShutdown()

Overrides:

triggerShutdown in class com.google.common.util.concurrent.AbstractExecutionThreadService

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class com.google.common.util.concurrent.AbstractExecutionThreadService