如何使用Go语言中的并发函数实现并行计算的任务分发?
引言:在计算机科学领域,任务分发是一种常见的并行计算技术。任务分发允许程序通过将一个大任务分解成多个小任务,并行地执行这些小任务。Go语言提供了强大的并发函数来实现任务分发,这让我们能够充分利用多核处理器的能力,加速程序的执行。
package main
import (
"fmt"
"sync"
)
func main() {
// 定义一个任务切片
tasks := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
// 创建一个用于接收结果的channel
results := make(chan int, len(tasks))
// 创建一个等待组
wg := sync.WaitGroup{}
// 遍历任务切片,为每个任务创建一个goroutine进行计算
for _, task := range tasks {
wg.Add(1)
go func(task int) {
defer wg.Done()
// 执行具体的计算任务
result := compute(task)
// 将计算结果发送到结果channel
results