milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

enhance: create goroutine only once (#28594) 

create goroutine only once when getOrCreateMergedTimeTickerSender

Signed-off-by: lixinguo <xinguo.li@zilliz.com>
Co-authored-by: lixinguo <xinguo.li@zilliz.com>
pull/28492/head
smellthemoon 2023-11-22 10:26:28 +08:00 committed by GitHub
parent e8c5e75786
commit 29249c4bd3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/datanode/flow_graph_time_ticker.go
View File

@ -64,10 +64,10 @@ func newUniqueMergedTimeTickerSender(send sendTimeTick) *mergedTimeTickerSender
func getOrCreateMergedTimeTickerSender(send sendTimeTick) *mergedTimeTickerSender {
getUniqueMergedTimeTickerSender.Do(func() {
uniqueMergedTimeTickerSender = newUniqueMergedTimeTickerSender(send)
uniqueMergedTimeTickerSender.wg.Add(2)
go uniqueMergedTimeTickerSender.tick()
go uniqueMergedTimeTickerSender.work()
})
uniqueMergedTimeTickerSender.wg.Add(2)
go uniqueMergedTimeTickerSender.tick()
go uniqueMergedTimeTickerSender.work()
return uniqueMergedTimeTickerSender
}