Golang多任务调度技巧全解析

func doTask(id int) {
    time.Sleep(1 * time.Second)
    fmt.Printf("任务 %d 完成\n", id)
}
func main() {
for i := 0; i < 5; i++ {
go doTask(i)
}
time.Sleep(2 * time.Second) // 等待所有任务完成
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i 

func taskWithResult(id int, ch chan string) {
    time.Sleep(1 * time.Second)
    ch func main() {
resultCh := make(chan string, 5)
for i := 0; i < 5; i++ {
go taskWithResult(i, resultCh)
}
for i := 0; i < 5; i++ {
    result := <-resultCh
    fmt.Println(result)
}
close(resultCh)
}

select {
case result := 

func limitedConcurrency() {
    sem := make(chan struct{}, 3) // 最大并发 3
    resultCh := make(chan string, 10)
tasks := []int{1, 2, 3, 4, 5, 6, 7, 8}

for _, id := range tasks {
    sem <- struct{}{} // 获取令牌
    go func(taskID int) {
        defer func() { <-sem }() // 释放令牌
        time.Sleep(1 * time.Second)
        resultCh <- fmt.Sprintf("处理完成: %d", taskID)
    }(id)
}

// 等待所有任务提交完毕并关闭 resultCh
go func() {
    for i := 0; i < cap(sem); i++ {
        sem <- struct{}{}
    }
    close(resultCh)
}()

for res := range resultCh {
    fmt.Println(res)
}
}