common

Documentation

Overview

Package taskpool provides limited pool running task

Index

• type Retry
  • func Timed(retryTimes int, delayTime uint32) Retry
  • func (r Retry) On(caller func() error) error
• type TaskPool
  • func New(workerCount, poolSize int) TaskPool
  • func (tp TaskPool) Close()
  • func (tp TaskPool) Run(task func())
  • func (tp TaskPool) TryRun(task func()) bool

Types

type Retry

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

func Timed

func Timed(retryTimes int, delayTime uint32) Retry

return a Retry delayTime is millisecond

func (Retry) On

func (r Retry) On(caller func() error) error

type TaskPool

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

TaskPool limited pool

func New

func New(workerCount, poolSize int) TaskPool

New returns task pool with workerCount and poolSize

func (TaskPool) Close

func (tp TaskPool) Close()

Close the pool, the function is concurrent unsafe

func (TaskPool) Run

func (tp TaskPool) Run(task func())

Run add task to pool, block if pool is full

func (TaskPool) TryRun

func (tp TaskPool) TryRun(task func()) bool

TryRun try to add task to pool, return immediately