channel可用于任务协调，如通过无缓冲channel实现完成信号，带缓冲channel控制并发数，结合context与select实现超时控制，并用close通知接收端退出，从而有效管理goroutine同步与资源清理。
在Go语言中，channel不仅是数据传递的工具，更是实现goroutine间任务协调的核心机制。通过合理使用channel，可以有效控制并发流程、同步执行顺序、避免竞态条件。下面结合常见场景说明如何用channel进行任务协调。
1. 等待任务完成（信号同步）
最简单的协调方式是使用无缓冲channel作为“完成信号”。主goroutine启动子任务后，等待其通过channel发送完成通知。
done := make(chan bool)
<p>go func() {
// 模拟耗时任务
time.Sleep(2 * time.Second)
done <- true // 任务完成，发送信号
}()</p><p>fmt.Println("任务开始...")
<-done // 阻塞等待任务结束
fmt.Println("任务完成")</p>这种方式替代了WaitGroup，在简单场景下更直观。
2. 控制并发数（工作池模式）
当需要限制同时运行的goroutine数量时，可用带缓冲的channel作为“许可证”控制并发。
立即学习“go语言免费学习笔记（深入）”；
semaphore := make(chan struct{}, 3) // 最多3个并发
<p>for i := 0; i < 10; i++ {
go func(id int) {
semaphore <- struct{}{} // 获取许可
defer func() { <-semaphore }() // 释放许可</p><pre class='brush:php;toolbar:false;'> fmt.Printf("任务 %d 开始\n", id)
time.Sleep(time.Second)
fmt.Printf("任务 %d 完成\n", id)
}(i)}
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
该模式适用于爬虫、批量请求等需限流的场景。
3. 多任务协同与超时控制
多个任务并行执行，主逻辑等待全部完成或超时退出，可结合select和context实现。
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
defer cancel()
<p>tasks := 3
done := make(chan bool, tasks)</p><p>for i := 0; i < tasks; i++ {
go func(id int) {
select {
case <-ctx.Done():
fmt.Printf("任务 %d 被取消\n", id)
default:
time.Sleep(time.Duration(rand.Intn(1500)) * time.Millisecond)
done <- true
}
}(i)
}</p><p>// 等待所有任务完成或超时
for i := 0; i < tasks; i++ {
select {
case <-done:
fmt.Println("一个任务完成")
case <-ctx.Done():
fmt.Println("等待超时，停止等待")
break
}
}</p>这种组合方式能优雅处理失败和延迟任务。
4. 主动关闭与资源清理
使用close(channel)通知所有监听者“不再有数据”，配合range自动退出循环。
dataCh := make(chan int)
done := make(chan bool)
<p>go func() {
for num := range dataCh { // 自动检测channel关闭
fmt.Println("处理数据:", num)
}
done <- true
}()</p><p>// 发送部分数据
for i := 0; i < 5; i++ {
dataCh <- i
}
close(dataCh) // 关闭channel，触发接收端退出</p><p><-done
fmt.Println("所有数据处理完毕")</p>这是实现生产者-消费者模型的标准做法。
基本上就这些。channel的本质是同步点，合理设计它的容量和使用方式，就能灵活协调各种并发任务。关键在于明确谁发信号、谁接收、何时关闭，避免死锁和泄露。
