并行与等待:如何构建包含并行与等待 Neuron 的 Brain
TrigLinks() 或 Entry() 是并行的触发 links 的 Neuron 完成后 Cast group 中的 links 也是并行触发的 Neuron 等待指定的上游全都执行完成后才开始执行。通过设置 trigger group 来定义需要等待哪些上游完成。 完整示例见: examples/flow-topology/parallel
var ( entryInput, entryPoetry, entryJoke string ) func main() { bp := zenmodel.NewBrainPrint() bp.AddNeuron("input", inputFn) bp.AddNeuron("poetry-template", poetryFn) bp.AddNeuron("joke-template", jokeFn) bp.AddNeuron("generate", genFn) inputIn, _ := bp.AddLink("input", "generate") poetryIn, _ := bp.AddLink("poetry-template", "generate") jokeIn, _ := bp.AddLink("joke-template", "generate") entryInput, _ = bp.AddEntryLink("input") entryPoetry, _ = bp.AddEntryLink("poetry-template") entryJoke, _ = bp.AddEntryLink("joke-template") _ = bp.