实时数据处理：使用Go WaitGroup处理数据流

在Go语言中，可以使用sync.WaitGroup来处理实时数据流。
sync.WaitGroup是一个计数信号量，用于等待一组goroutines的结束。它具有三个主要方法：Add()、Done() 和 Wait()。
首先需要创建一个sync.WaitGroup对象，然后在每个goroutine启动前调用Add()方法，表示要等待的goroutine数量增加 1。在 goroutine 末尾调用 Done() 方法表明 goroutine 已经结束。最后，在主goroutine中调用Wait()方法，等待所有goroutine结束。
下面是一个简单的例子。假设有一个数据流需要实时处理。处理任务是打印每个数据的平方值：

package mainimport (" fmt""sync")func main() {var wgsync.WaitGroupdataStream := []int{1, 2, 3, 4, 5}for _, data := range dataStream {wg.Add(1)go process( data, &wg)}wg.Wait()}func process(data int, wg *sync .WaitGroup) {defer wg.Done()result := data * datafmt.Println(result)}

在主函数中，一个sync.WaitGroup对象wg 首先被创建。然后遍历数据流，为每个数据添加一个等待任务。接下来，启动一个 goroutine 来处理每个数据，并传递 &wg 作为参数。在 process() 函数中，打印每个数据的平方值，并在函数末尾调用 wg.Done() 表示 goroutine 已完成结束了。
最后，在主函数中调用wg.Wait()等待所有goroutine结束。这确保了主函数在所有数据处理完毕之前不会退出。