upool

Documentation

Index

• Variables
• type LogLevel
  • func (ll LogLevel) GetType() string
• type TaskHandler
• type TaskOption
• type TaskPool
  • func NewTaskPool(capacity int, options ...TaskOption) *TaskPool
  • func (tp *TaskPool) Put(task TaskHandler) error
  • func (tp *TaskPool) Wait()
  • func (tp *TaskPool) WaitAndClose()

Variables

var (
	ErrTaskPoolClosed error = errors.New("task_pool already closed")
)

Types

type LogLevel

type LogLevel uint8

const (
	DebugLevel LogLevel = iota
	InfoLevel
	WarnLevel
	ErrorLevel
	FatalLevel
	PanicLevel
)

func (LogLevel) GetType

func (ll LogLevel) GetType() string

type TaskHandler

type TaskHandler interface {
	Execute()
}

type TaskOption

type TaskOption struct {
	RecoverHandler func(interface{})
	LogLevel       LogLevel
	IdleTime       int // seconds
}

type TaskPool

type TaskPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTaskPool

func NewTaskPool(capacity int, options ...TaskOption) *TaskPool

func (*TaskPool) Put

func (tp *TaskPool) Put(task TaskHandler) error

func (*TaskPool) Wait

func (tp *TaskPool) Wait()

func (*TaskPool) WaitAndClose

func (tp *TaskPool) WaitAndClose()