ordergroup

Documentation

Index

• type Option
• type OrderGroup
  • func New(n int, opt Option) *OrderGroup
  • func (g *OrderGroup) DoRank(i int, f Task)
  • func (g *OrderGroup) Start()
  • func (g *OrderGroup) Stop()
  • func (g *OrderGroup) Wait() []int
• type Task

Types

type Option

type Option struct {
	AutoWait bool
}

type OrderGroup

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

OrderGroup ensures a set of async tasks are performed in scheduled order.

func New

func New(n int, opt Option) *OrderGroup

New creates an OrderGroup of given size.

func (*OrderGroup) DoRank

func (g *OrderGroup) DoRank(i int, f Task)

DoRank starts the i-th (0 <= i < n) rank.

func (*OrderGroup) Start

func (g *OrderGroup) Start()

func (*OrderGroup) Stop

func (g *OrderGroup) Stop()

func (*OrderGroup) Wait

func (g *OrderGroup) Wait() []int

type Task

type Task func()