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

临时屏蔽

Browse Source
This commit is contained in:
redkale
2024-09-05 15:00:42 +08:00
parent 2506405d8c
commit aab8a631f0
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/ClientCodec.java
View File

@@ -149,11 +149,11 @@ public abstract class ClientCodec<R extends ClientRequest, P extends ClientResul
if (exc == null) { if (exc == null) {
final Object rs = request.respTransfer == null ? message : request.respTransfer.apply(message); final Object rs = request.respTransfer == null ? message : request.respTransfer.apply(message);
// workThread不区分IO线程，respFuture.complete中使用CompletableFuture.join会一直阻塞 // workThread不区分IO线程，respFuture.complete中使用CompletableFuture.join会一直阻塞
workThread.runWork(() -> { //workThread.runWork(() -> {
Traces.currentTraceid(request.traceid); Traces.currentTraceid(request.traceid);
respFuture.complete(rs); respFuture.complete(rs);
Traces.removeTraceid(); Traces.removeTraceid();
}); //});
} else { // 异常 } else { // 异常
workThread.runWork(() -> { workThread.runWork(() -> {
Traces.currentTraceid(request.traceid); Traces.currentTraceid(request.traceid);