syncronizer

Documentation

Index

• type Synchronizer
  • func NewSync(maxRoutines int) *Synchronizer
  • func (s *Synchronizer) AddLink(body func(*Task))
  • func (s *Synchronizer) Finish() (aborted bool)
• type Task
  • func (r *Task) AbortSync()
  • func (r *Task) Link() (close bool)

Types

type Synchronizer

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

func NewSync

func NewSync(maxRoutines int) *Synchronizer

func (*Synchronizer) AddLink

func (s *Synchronizer) AddLink(body func(*Task))

func (*Synchronizer) Finish

func (s *Synchronizer) Finish() (aborted bool)

type Task

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

func (*Task) AbortSync

func (r *Task) AbortSync()

func (*Task) Link

func (r *Task) Link() (close bool)

Link should be called exactly once inside the fn of every task.