Go语言并发编程如何实现任务并行

在Go语言中，可以使用goroutines和channels来实现任务并行。goroutines是Go语言的轻量级线程，可以并发执行多个任务。channels则用于在goroutines之间传递数据，实现同步和通信。

以下是一个简单的示例，展示了如何使用goroutines和channels实现任务并行：

package main

import (
 "fmt"
 "time"
)

func worker(id int, jobs <-chan int, results chan<- int) {
 for j := range jobs {
 fmt.Printf("Worker %d started job %d\n", id, j)
 time.Sleep(time.Second) // 模拟任务执行时间
 fmt.Printf("Worker %d finished job %d\n", id, j)
 results <- j * 2
 }
}

func main() {
 const numJobs = 5
 jobs := make(chan int, numJobs)
 results := make(chan int, numJobs)

 // 创建5个goroutines来处理任务
 for w := 1; w <= 3; w++ {
 go worker(w, jobs, results)
 }

 // 将任务发送到jobs通道
 for j := 1; j <= numJobs; j++ {
 jobs <- j
 }
 close(jobs)

 // 收集并打印任务结果
 for a := 1; a <= numJobs; a++ {
 <-results
 }
}

在上面的示例中，我们定义了一个worker函数，它接受一个ID、一个任务通道和一个结果通道作为参数。worker函数从任务通道中读取任务，模拟任务执行时间，然后将结果发送到结果通道。

在main函数中，我们创建了5个goroutines来处理任务，并将它们启动。然后，我们将5个任务发送到jobs通道。接下来，我们关闭jobs通道，表示没有更多的任务需要处理。最后，我们从结果通道中读取并打印任务结果。

运行上述代码，你将看到5个任务并行执行的情况。每个任务都由一个goroutine处理，它们之间通过jobs和results通道进行通信和同步。

这只是一个简单的示例，你可以根据自己的需求进行扩展和修改。Go语言提供了丰富的并发编程工具和库，可以帮助你更高效地实现任务并行。