From a0c5f94017c7447e89f3c6601c441763eee7868b Mon Sep 17 00:00:00 2001
From: Ulric Qin <ulric.qin@gmail.com>
Date: Thu, 21 Apr 2022 11:07:56 +0800
Subject: [PATCH] use goroutine to send metrics to backend

---
 src/server/writer/writer.go | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/src/server/writer/writer.go b/src/server/writer/writer.go
index 0bdff39c..898cea14 100644
--- a/src/server/writer/writer.go
+++ b/src/server/writer/writer.go
@@ -199,19 +199,11 @@ func (ws *WritersType) StartConsumer(ident string, ch chan *prompb.TimeSeries) {
 // post post series to TSDB
 // @Author: quzhihao
 func (ws *WritersType) post(ident string, series []*prompb.TimeSeries) {
-	wg := sync.WaitGroup{}
-	wg.Add(len(ws.backends))
-
 	// maybe as backend hashstring
 	headers := map[string]string{"ident": ident}
 	for key := range ws.backends {
-		go func(key string) {
-			defer wg.Done()
-			ws.backends[key].Write(series, headers)
-		}(key)
+		go ws.backends[key].Write(series, headers)
 	}
-
-	wg.Wait()
 }
 
 func NewWriters() WritersType {
-- 
GitLab