topo:用于创建由通道连接的 goroutines 的进程拓扑的库

托普 一个用于创建由通道连接的 goroutine 的进程内拓扑的库。 Topo 执行概述的样板工作。 您接收正确连接的输入和输出通道，在处理管道时为您留下消息处理。 Topo 力求简单，所有交互都通过适当的 Go 通道进行，没有包装接口。 示例代码 package main import ( "fmt" "sync" "github.com/mdmarek/topo" "github.com/mdmarek/topo/topoutil" ) const nworkers = 2 func worker ( in <- chan topo. Mesg , out chan <- topo. Mesg ) { ... do something ... } func main () { wg := new (sync. WaitGroup ) wg . Add ( nworke