Golangchannel任务协调方法解析

done := make(chan bool)
go func() {
// 模拟耗时任务
time.Sleep(2 * time.Second)
done <- true // 任务完成，发送信号
}()
fmt.Println("任务开始...")
<-done // 阻塞等待任务结束
fmt.Println("任务完成")

semaphore := make(chan struct{}, 3) // 最多3个并发
for i := 0; i < 10; i++ {
go func(id int) {
semaphore <- struct{}{} // 获取许可
defer func() { <-semaphore }() // 释放许可
    fmt.Printf("任务 %d 开始\n", id)
    time.Sleep(time.Second)
    fmt.Printf("任务 %d 完成\n", id)
}(i)
}

ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
defer cancel()
tasks := 3
done := make(chan bool, tasks)
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)
}
// 等待所有任务完成或超时
for i := 0; i < tasks; i++ {
select {
case <-done:
fmt.Println("一个任务完成")
case <-ctx.Done():
fmt.Println("等待超时，停止等待")
break
}
}

dataCh := make(chan int)
done := make(chan bool)
go func() {
for num := range dataCh { // 自动检测channel关闭
fmt.Println("处理数据:", num)
}
done <- true
}()
// 发送部分数据
for i := 0; i < 5; i++ {
dataCh <- i
}
close(dataCh) // 关闭channel，触发接收端退出
<-done
fmt.Println("所有数据处理完毕")