Examples of ChunkedPipelineConnection

org.jredis.ri.alphazero.connection.ChunkedPipelineConnection
WIP NOTES:
intended to replace existing pipeline per further tests. This pipeline:
- provides maximal throughput for asynchronous feedsto Redis server.
- it is thread-safe.

Design:

We're basically delegating output throttling concerns to the OS and the TCP/IP layer using blocking write semantics. The TCP layer will write MTU sized packets, regardless of actual user data, so clearly the more we pack per packet, the higher will be the throughput of the connector. @author Joubin

Examples of org.jredis.ri.alphazero.connection.ChunkedPipelineConnection

public class JRedisChunkedPipeline extends JRedisFutureSupport {


  final private Connection  connection;
  public JRedisChunkedPipeline(ConnectionSpec spec){
    assert spec != null : "spec is null";
    connection = new ChunkedPipelineConnection(spec);
  }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.