From d2ebbe2317ea06606533a293dcc977961651f400 Mon Sep 17 00:00:00 2001 From: smellthemoon <64083300+smellthemoon@users.noreply.github.com> Date: Wed, 22 Nov 2023 10:26:28 +0800 Subject: [PATCH] enhance: create goroutine only once(#28594) (#28609) create goroutine only once when getOrCreateMergedTimeTickerSender pr: #28594 Signed-off-by: lixinguo Co-authored-by: lixinguo --- internal/datanode/flow_graph_time_ticker.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/datanode/flow_graph_time_ticker.go b/internal/datanode/flow_graph_time_ticker.go index 7c4302b67f..039a7c07cb 100644 --- a/internal/datanode/flow_graph_time_ticker.go +++ b/internal/datanode/flow_graph_time_ticker.go @@ -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 }