yunfantec
/
mq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化短线后cpu飙升问题

This commit is contained in:
qiyunfanbo126.com 2025-01-22 13:50:59 +08:00
parent 679154720f
commit 2c62f5d38a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/utils/mq/kafka_v2.go
View File

@ -95,7 +95,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
go func() { go func() {
for { for {
if atomic.LoadInt32(tcppool.TcpFactory.Full) == 1 { if atomic.LoadInt32(tcppool.TcpFactory.Full) == 1 {
utils.Log(nil, "对列阻塞") //utils.Log(nil, "对列阻塞")
time.Sleep(100 * time.Millisecond) time.Sleep(100 * time.Millisecond)
continue continue
} else { } else {