kratos/pkg/sync/pipeline/fanout

pkg/sync/pipeline/fanout

功能:

• 支持定义Worker 数量的goroutine，进行消费
• 内部支持的元数据传递（pkg/net/metadata）

示例:

//名称为cache 执行线程为1 buffer长度为1024
cache := fanout.New("cache", fanout.Worker(1), fanout.Buffer(1024))
cache.Do(c, func(c context.Context) { SomeFunc(c, args...) })
cache.Close()