concurrency

Documentation

Index

• type Barrier
  • func NewBarrier(num int) *Barrier
  • func (b *Barrier) Advance()
  • func (b *Barrier) Done()

Examples

• Barrier

Types

type Barrier

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

Barrier for limited go-routines

Example

b := NewBarrier(15)
log.SetFlags(log.LstdFlags | log.Lmicroseconds)

wg := &sync.WaitGroup{}
for i := 0; i < 100; i++ {

	b.Advance()
	wg.Add(1)
	go func(i int) {
		defer wg.Done()
		defer b.Done()

		time.Sleep(time.Millisecond * 500)
		log.Printf("done %d", i)
	}(i)
}
wg.Done()

func NewBarrier

func NewBarrier(num int) *Barrier

NewBarrier creates new object and inits it

func (*Barrier) Advance

func (b *Barrier) Advance()

Advance 1 step if there still is a unused go-routine

func (*Barrier) Done

func (b *Barrier) Done()

Done means outside will release the go routine