小编tec*_*ger的帖子

我配置了多个接收器，并且有一个自定义丰富器，我只想将其应用于基于文本的接收器，例如 Console 和 RollingFile。

有没有办法做到这个串行？

预计:大约完成后完成 2秒

实际:无限期运行.

不明白可能导致它无限期运行的原因.

package main

import (
    "context"
    "fmt"
    "time"
)

func main() {
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()

    for i := range generator(ctx) {
        select {
        case <-time.After(2 * time.Second):
            cancel()
            return
        default:
            fmt.Println(i)
        }
    }
}

func generator(ctx context.Context) <-chan int {
    ch := make(chan int)

    go func() {
        count := 0
        for {
            select {
            case <-ctx.Done():
                return
            case ch <- count:
                count++
            }
        }
    }()

    return ch
}