如何使用 Channel 或 Context 等待多个子协程执行完毕？

协程等待：通过 channel 或 context 实现

想要等待多个子协程执行完毕，可以通过使用 channel 或 context 实现，类似于 sync.waitgroup 的功能。

channel

channel 用于在协程间通讯。可以通过创建一个缓冲 channel，并为每个协程发送一个值，来实现子协程完成后通知主协程。

ONLYOFFICE

用ONLYOFFICE管理你的网络私人办公室

下载

import "math/rand"
import "time"

func main() {
    const num = 10
    ch := make(chan int, num)

    for i := 0; i < num; i++ {
        go func() {
            fmt.println("goroutine start: ", i)
            t := rand.intn(5) + 1
            time.sleep(time.duration(t) * time.second)
            fmt.println("goroutine end: ", i)
            ch <- 0
        }()
    }

    fmt.println("main start")
    for i := 0; i < num; i++ {
        <-ch
        fmt.println("main get: ", i)
    }
    fmt.println("main end")
}

context

context 是一种更通用的机制，可以用来传播取消信号或其他值。可以通过使用 withcancel 函数创建一个 context，并传递给子协程。当主协程取消 context 时，子协程会自动终止。

import "context"

func main() {
    const num = 10

    ctx, cancel := context.WithCancel(context.Background())
    ch := make(chan int, num)

    for i := 0; i < num; i++ {
        go func(ctx context.Context) {
            fmt.Println("goroutine start: ", i)
            select {
            case <-ctx.Done():
                fmt.Println("goroutine cancelled: ", i)
                return
            default:
            }
            t := rand.Intn(5) + 1
            time.Sleep(time.Duration(t) * time.Second)
            fmt.Println("goroutine end: ", i)
            ch <- 0
        }(ctx)
    }

    fmt.Println("main start")
    for i := 0; i < num; i++ {
        <-ch
        fmt.Println("main get: ", i)
    }
    cancel()
    fmt.Println("main end")
}