Usage

import"github.com/marusama/cyclicbarrier"...b1:=cyclicbarrier.New(10)// new cyclic barrier with parties = 10...b2:=cyclicbarrier.NewWithAction(10,func()error {returnnil })// new cyclic barrier with parties = 10 and with defined barrier action

b.Await(ctx)// await other parties

b.Reset()// reset the barrier

Simple example

// create a barrier for 10 parties with an action that increments counter// this action will be called each time when all goroutines reach the barriercnt:=0b:=cyclicbarrier.NewWithAction(10,func()error {cnt++returnnil})wg:= sync.WaitGroup{}fori:=0;i<10;i++ {// create 10 goroutines (the same count as barrier parties)wg.Add(1)gofunc() {forj:=0;j<5;j++ {// do some hard work 5 timestime.Sleep(100*time.Millisecond)err:=b.Await(context.TODO())// ..and wait for other parties on the barrier.// Last arrived goroutine will do the barrier action// and then pass all other goroutines to the next roundiferr!=nil {panic(err)            }        }wg.Done()    }()}wg.Wait()fmt.Println(cnt)// cnt = 5, it means that the barrier was passed 5 times