Golang中的数据并发处理可以通过使用goroutine和channel来实现。Goroutine是一种轻量级的线程，可以在函数前添加go关键字来启动一个goroutine。Channel是用于goroutine之间进行通信和数据传递的数据结构。
下面是一个简单的示例，演示如何通过goroutine和channel实现数据并发处理：
func processData(data []int, result chan int) {// 处理数据sum := 0for _, value := range data {sum += value}result <- sum}func main() {data := []int{1, 2, 3, 4, 5}result := make(chan int)go processData(data[:len(data)/2], result)go processData(data[len(data)/2:], result)// 等待两个goroutine都完成total := <-result + <-resultfmt.Println("Total sum:", total)}在上面的例子中，我们将数据分成两部分，并在两个goroutine中处理。每个goroutine都将部分数据的和发送到result通道中。最后，通过从通道中读取两个结果并求和，我们得到了总和。
在Go中，如果有多个goroutine运行，并且我们需要等待它们全部完成后再继续执行，可以使用WaitGroup。WaitGroup是Go提供的一种同步原语，用于等待一组goroutine完成。
下面是一个使用WaitGroup的示例：
func processData(data []int, result chan int, wg *sync.WaitGroup) {defer wg.Done()// 处理数据sum := 0for _, value := range data {sum += value}result <- sum}func main() {data := []int{1, 2, 3, 4, 5}result := make(chan int)var wg sync.WaitGroupwg.Add(2) // 添加两个goroutine到WaitGroupgo processData(data[:len(data)/2], result, &wg)go processData(data[len(data)/2:], result, &wg)go func() {wg.Wait() // 等待所有goroutine完成close(result)}()// 从通道中读取结果total := 0for value := range result {total += value}fmt.Println("Total sum:", total)}在上面的例子中，我们使用sync库中的WaitGroup来进行goroutine的同步。首先，我们在main函数中创建一个WaitGroup，并使用Add方法将待等待的goroutine数量设置为2。然后，在每个goroutine的末尾，我们调用Done方法来表示该goroutine已经完成。最后，我们使用Wait方法等待所有的goroutine完成。
需要注意的是，我们使用了一个匿名的goroutine来等待所有的goroutine完成，然后关闭result通道。在主函数中，我们使用range循环从result通道中读取结果，并计算出总和。
这就是在Golang中进行数据并发处理以及使用WaitGroup的基本方法。通过goroutine和channel，我们可以方便地实现并发处理，并且通过WaitGroup可以确保所有的goroutine都完成后再进行下一步操作。
