Golang中实现并发任务有序执行主要有四种方式：1. 用channel顺序控制，单goroutine依次处理；2. 用WaitGroup配合索引确保结果按输入顺序收集；3. 用带缓冲channel限流并保持FIFO顺序；4. 用sync.Mutex保护共享状态以串行化关键操作。
在Golang中，并发任务默认是无序执行的，因为goroutine由调度器动态管理。但在某些场景下，比如数据处理流水线、状态依赖操作或日志写入，我们需要保证任务按特定顺序执行。以下是几种常见的实现方式来确保并发任务的有序性。
使用channel进行顺序控制
Channel是Golang中最基础的同步机制之一，通过它可以在goroutine之间传递数据并控制执行流程。
说明：将任务放入channel，由单个goroutine依次读取并处理，天然保证顺序。
示例：func orderedByChannel(tasks []func()) {
ch := make(chan func(), len(tasks))
done := make(chan bool)
// 启动单个worker顺序处理
go func() {
for task := range ch {
task()
}
done <- true
}()
// 按顺序发送任务
for _, task := range tasks {
ch <- task
}
close(ch)
<-done}
这种方式适合任务本身不并发，但需异步触发执行的场景。
利用WaitGroup配合有序启动
如果多个任务可以并发执行，但结果需要按顺序收集，则可结合sync.WaitGroup与索引标记。
说明：每个任务完成后将结果写入对应索引的切片，主协程等待全部完成后再按序输出。
示例：func orderedResultWithWg(tasks []func() string) []string {
n := len(tasks)
results := make([]string, n)
var wg sync.WaitGroup
for i, task := range tasks {
wg.Add(1)
go func(idx int, t func() string) {
defer wg.Done()
results[idx] = t()
}(i, task)
}
wg.Wait()
return results // 按原始顺序返回}
适用于任务可并发执行但输出需保持输入顺序的情况，如批量HTTP请求按发起顺序返回结果。
使用带缓冲channel模拟队列
当任务量大且希望限制并发数同时保持顺序时，可用生产者-消费者模型。
说明：生产者按序发送任务，消费者数量可控，处理顺序仍由channel FIFO特性保障。
示例：func semaphoredOrder(tasks []func(), maxConcurrency int) {
ch := make(chan func(), maxConcurrency)
// 启动固定数量worker
var wg sync.WaitGroup
for i := 0; i < maxConcurrency; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for task := range ch {
task()
}
}()
}
// 按顺序发送任务到channel
for _, task := range tasks {
ch <- task
}
close(ch)
wg.Wait()}
此方法兼顾性能与顺序，常用于爬虫、文件处理等高并发但需控速的场景。
使用sync.Mutex保护共享状态
当多个goroutine需更新同一资源且顺序敏感时，可用互斥锁控制访问。
说明：虽然goroutine并发运行，但关键区段串行执行，间接维持逻辑顺序。
示例：var mu sync.Mutex
var logLines []string
func appendLogSafe(line string) {
mu.Lock()
defer mu.Unlock()
logLines = append(logLines, line) // 保证写入顺序
}
适合日志记录、状态累积等场景，注意避免长时间持有锁影响性能。
基本上就这些。选择哪种方式取决于具体需求：是否需要真正并发、顺序是指启动、执行还是结果输出。合理利用channel、WaitGroup和mutex，就能在Golang中灵活实现任务的有序管理。
这种方式适合任务本身不并发，但需异步触发执行的场景。
