syncx

Documentation

Index

• Variables
• type CyclicBarrier
  • func NewCyclicBarrier(n int, onAllArrived func() error) *CyclicBarrier
  • func (b *CyclicBarrier) Await(ctx context.Context) error
  • func (b *CyclicBarrier) IsBroken() bool
  • func (b *CyclicBarrier) NumWaiting() int
  • func (b *CyclicBarrier) Reset()
• type OnceIf
  • func (o *OnceIf) Do(f func() error) error
  • func (o *OnceIf) Done() bool

Variables

var ErrCyclicBarrierBroken = errors.New("broken barrier")

Types

type CyclicBarrier

type CyclicBarrier struct {
	// contains filtered or unexported fields
}

func NewCyclicBarrier

func NewCyclicBarrier(n int, onAllArrived func() error) *CyclicBarrier

func (*CyclicBarrier) Await

func (b *CyclicBarrier) Await(ctx context.Context) error

func (*CyclicBarrier) IsBroken

func (b *CyclicBarrier) IsBroken() bool

func (*CyclicBarrier) NumWaiting

func (b *CyclicBarrier) NumWaiting() int

func (*CyclicBarrier) Reset

func (b *CyclicBarrier) Reset()

type OnceIf

type OnceIf struct {
	// contains filtered or unexported fields
}

func (*OnceIf) Do

func (o *OnceIf) Do(f func() error) error

func (*OnceIf) Done

func (o *OnceIf) Done() bool