1

2022-12-16 10:41:56 +08:00
parent c92f7c9955
commit 2ca0df3f40
1 changed files with 3 additions and 2 deletions
--- a/business/jxstore/event/event_tcp.go
+++ b/business/jxstore/event/event_tcp.go
@@ -196,10 +196,11 @@ func (t *TcpClient) doPrint(key string) (err error) {
 	}
 	go func() {
 		for {
-			if t.readTimeoutMap(key) {
+			select {
+			case <-t.TimeoutMap[key]:
 				globals.SugarLogger.Debugf("doPrint timeout")
 				return
-			} else {
+			default:
 				select {
 				case printMsg, ok := <-t.MsgMap[key]:
 					if !ok {