| commit | b7d9392506715ae26b4fd7e877410a429891ab18 | |
| author | dreiss <dreiss@13f79535-47bb-0310-9956-ffa450edef68> | |
| Wed, 2 Jul 2008 23:55:04 +0000 (2 23:55 +0000) | ||
| committer | dreiss <dreiss@13f79535-47bb-0310-9956-ffa450edef68> | |
| Wed, 2 Jul 2008 23:55:04 +0000 (2 23:55 +0000) | ||
| tree | a00b1ab393781ec05741f31757cc53681036d5b0 | treesnapshot (tar.gz zip) |
| parent | 09cee7eb4e3ae90b8dff983a0af056efd4b9facf | commitdiff |
(THRIFT-5) A TNonblockingServers (single-threaded and thread-pool) for Java
This patch adds two Thrift servers for Java that both use non-blocking I/O
to avoid locking up worker threads for idle connections. The two classes are
- TNonblockingServer, which supports single-threaded serving
- THsHaServer, which performs I/O in one thread and method invocations in
a configurable thread pool.
To support these servers, TNonblockingServerSocket and TNonblockingSocket
have been added.
git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@673550 13f79535-47bb-0310-9956-ffa450edef68
This patch adds two Thrift servers for Java that both use non-blocking I/O
to avoid locking up worker threads for idle connections. The two classes are
- TNonblockingServer, which supports single-threaded serving
- THsHaServer, which performs I/O in one thread and method invocations in
a configurable thread pool.
To support these servers, TNonblockingServerSocket and TNonblockingSocket
have been added.
git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@673550 13f79535-47bb-0310-9956-ffa450edef68
| lib/java/src/com/facebook/thrift/server/THsHaServer.java | [new file with mode: 0644] | blob |
| lib/java/src/com/facebook/thrift/server/TNonblockingServer.java | [new file with mode: 0644] | blob |
| lib/java/src/com/facebook/thrift/transport/TFramedTransport.java | diffblobblamehistory | |
| lib/java/src/com/facebook/thrift/transport/TNonblockingServerSocket.java | [new file with mode: 0644] | blob |
| lib/java/src/com/facebook/thrift/transport/TNonblockingServerTransport.java | [new file with mode: 0644] | blob |
| lib/java/src/com/facebook/thrift/transport/TNonblockingSocket.java | [new file with mode: 0644] | blob |
| lib/java/src/com/facebook/thrift/transport/TNonblockingTransport.java | [new file with mode: 0644] | blob |
| lib/java/src/com/facebook/thrift/transport/TTransport.java | diffblobblamehistory | |
| test/java/TestNonblockingServer | [new file with mode: 0644] | blob |
| test/java/src/TestClient.java | diffblobblamehistory | |
| test/java/src/TestNonblockingServer.java | [new file with mode: 0644] | blob |