Install

go get github.com/buptmiao/parallel

Usage

eg.1

import ("github.com/buptmiao/parallel")functestJobA()string {return"job"}functestJobB(x,yint)int {returnx+y}functestJobC(xint)int {return-x}funcmain() {varsstringvarx,yintp:=parallel.NewParallel()p.Register(testJobA).SetReceivers(&s)p.Register(testJobB,1,2).SetReceivers(&x)p.Register(testJobC,3).SetReceivers(&y)// block herep.Run()ifs!="job"||x!=3||y!=-3{panic("unexpected result")}}

eg.2

jobA  jobB   jobC \      \     /  \      \   /   \      middle    \      /     \    /     final

import ("github.com/buptmiao/parallel")typemiddlestruct {BintCint}typetestResultstruct {AstringMmiddle}functestJobA()string {return"job"}functestJobB(x,yint)int {returnx+y}functestJobC(xint)int {return-x}functestFinal(s*string,m*middle)testResult {returntestResult{*s,*m,}}funcmain() {varmmiddlevarsstringvarrestestResultp:=parallel.NewParallel()// Create a child 1child1:=p.NewChild()child1.Register(testJobA).SetReceivers(&s)// Create another child 2child2:=p.NewChild()child2.Register(testJobB,1,2).SetReceivers(&m.B)child2.Register(testJobC,2).SetReceivers(&m.C)p.Register(testFinal,&s,&m).SetReceivers(&res)// block herep.Run()expect:=testResult{"job",middle{3,-2,},}ifres!=expect {panic("unexpected result")}}

eg.3

// handle the panicfuncexceptionHandler(topicstring,einterface{}) {fmt.Println(topic,e)}// will panicfuncexceptionJob() {varamap[string]int//assignment to entry in nil mapa["123"]=1}funcmain() {p:=parallel.NewParallel()p.Register(exceptionJob)// miss the last argument on purposep.Except(exceptionHandler,"topic1")p.Run()}

more examples