gbatch

Documentation

Index

• type Executor
  • func NewBatchExecutor() *Executor
  • func (s *Executor) AppendTask(tasks ...task)
  • func (s *Executor) SetPanicHandler(panicHandler func(e interface{}))
  • func (s *Executor) SetWorkers(workersCnt int)
  • func (s *Executor) WaitAll() (allResults []taskResult)
  • func (s *Executor) WaitFirstDone() (value interface{}, err error)
  • func (s *Executor) WaitFirstSuccess() (value interface{}, err error)

Types

type Executor

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

func NewBatchExecutor

func NewBatchExecutor() *Executor

func (*Executor) AppendTask

func (s *Executor) AppendTask(tasks ...task)

func (*Executor) SetPanicHandler

func (s *Executor) SetPanicHandler(panicHandler func(e interface{}))

func (*Executor) SetWorkers

func (s *Executor) SetWorkers(workersCnt int)

func (*Executor) WaitAll

func (s *Executor) WaitAll() (allResults []taskResult)

func (*Executor) WaitFirstDone

func (s *Executor) WaitFirstDone() (value interface{}, err error)

WaitFirstDone wait first done, value and err is the task returned.

func (*Executor) WaitFirstSuccess

func (s *Executor) WaitFirstSuccess() (value interface{}, err error)

WaitFirstSuccess wait first success, value is the first success task's returned value, if all task fail, err is the last error.