Golang中的数据并发处理可以通过使用goroutine和channel来实现。Goroutine是一种轻量级的线程，可以在函数前添加go关键字来启动一个goroutine。Channel是用于goroutine之间进行通信和数据传递的数据结构。
下面是一个简单的示例，演示如何通过goroutine和channel实现数据并发处理：
```
func processData(data []int, result chan int) {
// 处理数据
sum := 0
for _, 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 + <-result
fmt.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 := 0
for _, value := range data {
sum += value
}
result <- sum
}
func main() {
data := []int{1, 2, 3, 4, 5}
result := make(chan int)
var wg sync.WaitGroup
wg.Add(2) // 添加两个goroutine到WaitGroup
go processData(data[:len(data)/2], result, &wg)
go processData(data[len(data)/2:], result, &wg)
go func() {
wg.Wait() // 等待所有goroutine完成
close(result)
}()
// 从通道中读取结果
total := 0
for 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都完成后再进行下一步操作。
