go中搭建并行处理管理怎么做？

贵哥的编程之路

发布于 2024-03-19 09:16:35

690

发布于 2024-03-19 09:16:35

package main

import (
	"fmt"
	"time"
)

func worker(id int, jobs <-chan int, results chan<- int) {//id:代表该 worker 的标识符。, jobs <-chan int接收任务(只读 单向(通常用于向函数传递数据)).results chan<- int:单向 可写.发送数据的。通常用于函数向外部传递数据
//for j := range jobs 使用 range 关键字在循环中迭代 jobs 通道，从中接收任务。这种方式会一直等待并阻塞，直到 jobs 通道被关闭。

	for j := range jobs {
		fmt.Println("Worker", id, "processing job", j)
		time.Sleep(time.Second) //表示让当前 goroutine 休眠一秒钟的时间。
		results <- j * 2
	}
}

func main() {
	numJobs := 5
	jobs := make(chan int, numJobs)//传递任务
	results := make(chan int, numJobs)//处理结果

	// 启动多个 goroutine 来处理任务
	for w := 1; w <= 3; w++ {
		go worker(w, jobs, results)
	}

	// 提供一些任务
	/*它将整数值从 1 递增到 numJobs，然后将每个值发送到名为 jobs 的通道中*/
	for j := 1; j <= numJobs; j++ {
		jobs <- j
	}
	close(jobs)
	//为什么close(jobs)
	/*当发送方关闭通道时，接收方可以通过通道的关闭状态来判断是否还有数据需要接收。这可以避免接收方在等待数据时永远阻塞。*/

	// 收集处理结果
	/*它从 results 通道中接收数据，并且重复执行直到接收到 numJobs 个数据为止。*/
	for a := 1; a <= numJobs; a++ {
		<-results
	}
}

/*在这个示例中，我们首先创建了两个 int 类型的通道 jobs 和 results，
用于传递任务和处理结果。然后，我们启动了多个 worker goroutine 来处理任务，
并在主 goroutine 中提供了一些任务。每个 worker 会从 jobs 通道中接收任务
，处理完后将结果发送到 results 通道中。

通过这种方式，我们可以轻松地搭建并行处理管理，让多个任务可以并发处理，
同时保持任务处理结果的顺序。当所有任务都处理完成后，程序会退出主 goroutine。*/