summaryrefslogtreecommitdiff
path: root/lib/java/src/main/java/org/apache/thrift/server/TThreadPoolServer.java
diff options
context:
space:
mode:
Diffstat (limited to 'lib/java/src/main/java/org/apache/thrift/server/TThreadPoolServer.java')
-rw-r--r--lib/java/src/main/java/org/apache/thrift/server/TThreadPoolServer.java7
1 files changed, 5 insertions, 2 deletions
diff --git a/lib/java/src/main/java/org/apache/thrift/server/TThreadPoolServer.java b/lib/java/src/main/java/org/apache/thrift/server/TThreadPoolServer.java
index 357410f39..82d3a29d4 100644
--- a/lib/java/src/main/java/org/apache/thrift/server/TThreadPoolServer.java
+++ b/lib/java/src/main/java/org/apache/thrift/server/TThreadPoolServer.java
@@ -82,7 +82,7 @@ public class TThreadPoolServer extends TServer {
}
// Executor service for handling client connections
- private ExecutorService executorService_;
+ private final ExecutorService executorService_;
private final TimeUnit stopTimeoutUnit;
@@ -140,6 +140,7 @@ public class TThreadPoolServer extends TServer {
return true;
}
+ @Override
public void serve() {
if (!preServe()) {
return;
@@ -196,6 +197,7 @@ public class TThreadPoolServer extends TServer {
return false;
}
+ @Override
public void stop() {
stopped_ = true;
serverTransport_.interrupt();
@@ -204,7 +206,7 @@ public class TThreadPoolServer extends TServer {
private class WorkerProcess implements Runnable {
/** Client that this services. */
- private TTransport client_;
+ private final TTransport client_;
/**
* Default constructor.
@@ -216,6 +218,7 @@ public class TThreadPoolServer extends TServer {
}
/** Loops on processing a client forever */
+ @Override
public void run() {
TProcessor processor = null;
TTransport inputTransport = null;