tasks

Documentation

Index

• Variables
• type TaskFunc
• type Tasks
  • func (this *Tasks) Close() error
  • func (this *Tasks) Start(funcs ...TaskFunc)

Variables

var DONE = struct{}{}

Types

type TaskFunc

type TaskFunc func(start chan<- struct{}, stop <-chan struct{}) error

type Tasks

type Tasks struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func (*Tasks) Close

func (this *Tasks) Close() error

Close sends done signals to each go routine and will return any error from the tasks. Each go routine may end before the 'stop' signal is returned...

func (*Tasks) Start

func (this *Tasks) Start(funcs ...TaskFunc)

Start tasks in the background and waits for all "start" signals to be returned before unblocking