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

优化client

Browse Source
This commit is contained in:
redkale
2023-02-04 20:21:41 +08:00
parent eef43e8edc
commit e9d25a67f8
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/redkale/net/client/ClientWriteIOThread.java
View File

@@ -60,7 +60,7 @@ public class ClientWriteIOThread extends AsyncIOThread {
map.clear(); map.clear();
if (entry.resumeHalfRequestFlag != null) { //将暂停的pauseRequests写入list if (entry.resumeHalfRequestFlag != null) { //将暂停的pauseRequests写入list
List<ClientFuture> cl = map.computeIfAbsent(entry.conn, c -> listPool.get()); List<ClientFuture> cl = map.computeIfAbsent(entry.conn, c -> listPool.get());
for (ClientFuture f : (List<ClientFuture>) entry.conn.pauseRequests) { for (ClientFuture f : (Collection<ClientFuture>) entry.conn.pauseRequests) {
if (!f.isDone()) { if (!f.isDone()) {
entry.conn.offerRespFuture(f); entry.conn.offerRespFuture(f);
cl.add(f); cl.add(f);
@@ -79,7 +79,7 @@ public class ClientWriteIOThread extends AsyncIOThread {
while ((entry = requestQueue.poll()) != null) { while ((entry = requestQueue.poll()) != null) {
if (entry.resumeHalfRequestFlag != null) { //将暂停的pauseRequests写入list if (entry.resumeHalfRequestFlag != null) { //将暂停的pauseRequests写入list
List<ClientFuture> cl = map.computeIfAbsent(entry.conn, c -> listPool.get()); List<ClientFuture> cl = map.computeIfAbsent(entry.conn, c -> listPool.get());
for (ClientFuture f : (List<ClientFuture>) entry.conn.pauseRequests) { for (ClientFuture f : (Collection<ClientFuture>) entry.conn.pauseRequests) {
if (!f.isDone()) { if (!f.isDone()) {
entry.conn.offerRespFuture(f); entry.conn.offerRespFuture(f);
cl.add(f); cl.add(f);