lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ClientFuture优化

Browse Source
This commit is contained in:
Redkale
2023-01-18 11:22:09 +08:00
parent 4d42f94be4
commit f34ec61458
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/redkale/net/client/ClientCodec.java
View File

@@ -27,7 +27,7 @@ import org.redkale.util.*;
*/ */
public abstract class ClientCodec<R extends ClientRequest, P> implements CompletionHandler<Integer, ByteBuffer> { public abstract class ClientCodec<R extends ClientRequest, P> implements CompletionHandler<Integer, ByteBuffer> {
protected final ClientConnection connection; protected final ClientConnection<R, P> connection;
private final List<ClientResponse<R, P>> respResults = new ArrayList<>(); private final List<ClientResponse<R, P>> respResults = new ArrayList<>();
@@ -35,7 +35,7 @@ public abstract class ClientCodec<R extends ClientRequest, P> implements Complet
private final ObjectPool<ClientResponse<R, P>> respPool = ObjectPool.createUnsafePool(256, t -> new ClientResponse(), ClientResponse::prepare, ClientResponse::recycle); private final ObjectPool<ClientResponse<R, P>> respPool = ObjectPool.createUnsafePool(256, t -> new ClientResponse(), ClientResponse::prepare, ClientResponse::recycle);
public ClientCodec(ClientConnection connection) { public ClientCodec(ClientConnection<R, P> connection) {
Objects.requireNonNull(connection); Objects.requireNonNull(connection);
this.connection = connection; this.connection = connection;
} }
@@ -153,8 +153,12 @@ public abstract class ClientCodec<R extends ClientRequest, P> implements Complet
connection.dispose(t); connection.dispose(t);
} }
protected R nextRequest() {
return connection.findRequest(null);
}
protected R findRequest(Serializable requestid) { protected R findRequest(Serializable requestid) {
return (R) connection.findRequest(requestid); return connection.findRequest(requestid);
} }
public void addMessage(R request, P result) { public void addMessage(R request, P result) {