Golang通过 并发计算平方 示例演示并发

示例

以下代码演示了如何使用 Goroutines 并发计算一组数字的平方，并通过通道收集结果。

package main

import (
	"fmt"
	"time"
)

// worker 函数，用于计算一个数字的平方，并将结果发送到通道
func worker(id int, numbers <-chan int, results chan<- int) {
	for number := range numbers {
		fmt.Printf("Worker %d is processing number %d\n", id, number)
		time.Sleep(time.Second) // 模拟一些耗时操作
		results <- number * number
	}
}

func main() {
	// 创建两个通道：一个用于传递任务，另一个用于接收结果
	numbers := make(chan int, 10)
	results := make(chan int, 10)

	// 启动 3 个 worker goroutines
	for i := 1; i <= 3; i++ {
		go worker(i, numbers, results)
	}

	// 向 numbers 通道发送任务
	for i := 1; i <= 10; i++ {
		numbers <- i
	}
	close(numbers) // 关闭 numbers 通道，表示不再发送任务

	// 从 results 通道接收结果
	for i := 1; i <= 10; i++ {
		result := <-results
		fmt.Printf("Result: %d\n", result)
	}
}

代码说明

1. worker 函数：

• 每个 worker 从 numbers 通道中取出一个数字，计算其平方，并将结果发送到 results 通道。
• 使用 range 从通道中读取数据，直到通道关闭。

2. 主函数：

• 创建了两个通道：numbers 用于存放待处理的任务，results 用于存放计算结果。
• 启动了 3 个 Goroutines，每个 Goroutine 都运行 worker 函数。
• 将 1 到 10 的数字发送到 numbers 通道，随后关闭通道。
• 最后，从 results 通道中读取并打印所有计算结果。
  3、 并发执行：
• 由于同时启动了 3 个 Goroutines，多个任务会被并发处理，从而提高处理效率。

输出示例

运行程序后，你会看到类似以下的输出：

Worker 1 is processing number 1
Worker 2 is processing number 2
Worker 3 is processing number 3
Worker 1 is processing number 4
Worker 2 is processing number 5
Worker 3 is processing number 6
Result: 1
Result: 4
Result: 9
Result: 16
Result: 25
Result: 36
...

每次运行程序时，任务的分配可能会有所不同，因为 Goroutines 的调度是非确定性的。