From edcd9c6ffb1d31da0966e88e2ba70beed6466628 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 16 Dec 2022 15:25:39 +0800 Subject: [PATCH] 1 --- business/jxstore/event/event_tcp.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 65cfd73d4..87df0f658 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -166,9 +166,9 @@ func (t *TcpClient) HandleTcpMessages(printNo string) { go func() { for { - if time.Now().Second()%2 != 0 { - continue - } + //if time.Now().Second()%2 != 0 { + // continue + //} select { case <-t.TimeoutMap[printNo]: globals.SugarLogger.Debugf("HandleTcpMessages timeout") @@ -260,7 +260,6 @@ func (t *TcpClient) doPrint(key string) (err error) { close(t.TimeoutMap[key]) } else { //等待回调 - delete(t.MsgMap, key) dataStr := <-t.CallBackMap[printMsg.PrintNo] if dataStr != "" { a, b := getCallbackMsgInfo(dataStr)