Go工作流中的任务并行与串行处理

Go语言通过其原生协程（goroutines）和通道（channels）机制，使得任务并行与串行处理变得非常简单和高效。以下是Go中并行与串行处理的相关介绍：

串行处理

• 定义：串行处理是指任务按照顺序一个接一个地执行，前一个任务完成后，下一个任务才开始执行。
• 优点：实现简单，逻辑清晰。
• 缺点：当任务中存在I/O阻塞时，整个程序的执行效率会降低，因为CPU在此期间是空闲的。
• 示例：

package main

import (
	"fmt"
	"time"
)

type Task struct {
	Duration time.Duration
	Name     string
}

func main() {
	taskList := []Task{
		{1 * time.Second, "处理1"},
		{2 * time.Second, "处理2"},
		{3 * time.Second, "处理3"},
	}
	startTime := time.Now()
	for _, item := range taskList {
		go process(item)
	}
	fmt.Printf("用时:%v\n", time.Since(startTime))
}

func process(task Task) {
	time.Sleep(task.Duration) // 模拟I/O阻塞
	fmt.Printf("任务:%s 处理完毕\n", task.Name)
}

并行处理

• 定义：并行处理是指多个任务在同一时间内同时执行。
• 优点：能够显著提高程序的执行效率，尤其是在处理包含大量I/O操作的任务时。
• 缺点：需要额外的同步机制来确保数据的一致性。
• 示例：

package main

import (
	"fmt"
	"sync"
	"time"
)

type Task struct {
	Duration time.Duration
	Name     string
}

func main() {
	taskList :=。