zpool

Documentation

Index

• Variables
• type PanicFunc
• type Task
• type WorkPool
  • func New(min int, max ...int) *WorkPool
  • func (wp *WorkPool) AdjustSize(workSize int)
  • func (wp *WorkPool) Cap() uint
  • func (wp *WorkPool) Close()
  • func (wp *WorkPool) Continue(workerNum ...int)
  • func (wp *WorkPool) Do(fn Task) error
  • func (wp *WorkPool) DoWithTimeout(fn Task, t time.Duration) error
  • func (wp *WorkPool) IsClosed() bool
  • func (wp *WorkPool) PanicFunc(handler PanicFunc)
  • func (wp *WorkPool) Pause()
  • func (wp *WorkPool) PreInit() error

Variables

var (
	ErrPoolClosed  = errors.New("pool has been closed")
	ErrWaitTimeout = errors.New("pool wait timeout")
)

Types

type PanicFunc

type PanicFunc func(err error)

type Task

type Task func()

Task Define function callbacks

type WorkPool

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

func New

func New(min int, max ...int) *WorkPool

func (*WorkPool) AdjustSize

func (wp *WorkPool) AdjustSize(workSize int)

AdjustSize adjust the pool size

func (*WorkPool) Cap

func (wp *WorkPool) Cap() uint

Cap get the number of coroutines

func (*WorkPool) Close

func (wp *WorkPool) Close()

Close close the pool

func (*WorkPool) Continue

func (wp *WorkPool) Continue(workerNum ...int)

Continue continue

func (*WorkPool) Do

func (wp *WorkPool) Do(fn Task) error

Do Add to the workpool and implement

func (*WorkPool) DoWithTimeout

func (wp *WorkPool) DoWithTimeout(fn Task, t time.Duration) error

func (*WorkPool) IsClosed

func (wp *WorkPool) IsClosed() bool

IsClosed Has it been closed

func (*WorkPool) PanicFunc

func (wp *WorkPool) PanicFunc(handler PanicFunc)

Do Add to the workpool and implement

func (*WorkPool) Pause

func (wp *WorkPool) Pause()

Pause pause

func (*WorkPool) PreInit

func (wp *WorkPool) PreInit() error