parallel

README

Parallel

Parallel tools used by RAI and CarML

Documentation

Index

• type NonCancelableTask
  • func (NonCancelableTask) Cancelable() bool
• type NonCancelableTaskFunc
  • func (NonCancelableTaskFunc) Cancelable() bool
  • func (f NonCancelableTaskFunc) Run()
• type Parallel
  • func New(max int) Parallel
• type ParallelImpl
  • func (p *ParallelImpl) Add(task Task)
  • func (p *ParallelImpl) Run()
  • func (p *ParallelImpl) Start() Parallel
  • func (p *ParallelImpl) Stop()
  • func (p *ParallelImpl) Wait()
• type Task

Types

type NonCancelableTask

type NonCancelableTask struct {
}

func (NonCancelableTask) Cancelable

func (NonCancelableTask) Cancelable() bool

type NonCancelableTaskFunc

type NonCancelableTaskFunc func()

func (NonCancelableTaskFunc) Cancelable

func (NonCancelableTaskFunc) Cancelable() bool

func (NonCancelableTaskFunc) Run

func (f NonCancelableTaskFunc) Run()

type Parallel

type Parallel interface {
	Start() Parallel
	Wait()
	Stop()
	Add(Task)
	Run()
}

func New

func New(max int) Parallel

type ParallelImpl

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

func (*ParallelImpl) Add

func (p *ParallelImpl) Add(task Task)

func (*ParallelImpl) Run

func (p *ParallelImpl) Run()

func (*ParallelImpl) Start

func (p *ParallelImpl) Start() Parallel

func (*ParallelImpl) Stop

func (p *ParallelImpl) Stop()

func (*ParallelImpl) Wait

func (p *ParallelImpl) Wait()

type Task

type Task interface {
	Cancelable() bool
	Run()
}