taskpool

README

taskpool

Documentation

Index

• Constants
• Variables
• func Init(capacity int, opts ...Option)
• func Submit(ctx context.Context, task func()) error
• type Option
  • func WithMaxBlockingTasks(maxBlockingTasks int) Option
  • func WithNonBlocking() Option
• type Options
  • func NewOptions() *Options
  • func (o *Options) Apply(opts ...Option)
• type Pool
  • func NewPool(capacity int, opts ...Option) (*Pool, error)
  • func (p *Pool) Cap() int
  • func (p *Pool) IsClosed() bool
  • func (p *Pool) Release()
  • func (p *Pool) Running() int
  • func (p *Pool) Submit(ctx context.Context, f func()) error
  • func (p *Pool) Waiting() int

Constants

const (
	DefaultPoolCapacity    = 10
	DefaultExpiredDuration = time.Second
)

Variables

var (
	ErrPoolIsReleased = errors.New("pool is released")
	ErrPoolIsFull     = errors.New("pool is full")
	ErrPoolIsOverload = errors.New("pool is overload")
)

Functions

func Init

func Init(capacity int, opts ...Option)

func Submit

func Submit(ctx context.Context, task func()) error

Submit 提交task

Types

type Option

type Option func(o *Options)

func WithMaxBlockingTasks

func WithMaxBlockingTasks(maxBlockingTasks int) Option

func WithNonBlocking

func WithNonBlocking() Option

type Options

type Options struct {
	ExpiredDuration  time.Duration
	MaxBlockingTasks int
	Nonblocking      bool
}

func NewOptions

func NewOptions() *Options

func (*Options) Apply

func (o *Options) Apply(opts ...Option)

type Pool

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

func NewPool

func NewPool(capacity int, opts ...Option) (*Pool, error)

func (*Pool) Cap

func (p *Pool) Cap() int

func (*Pool) IsClosed

func (p *Pool) IsClosed() bool

func (*Pool) Release

func (p *Pool) Release()

func (*Pool) Running

func (p *Pool) Running() int

func (*Pool) Submit

func (p *Pool) Submit(ctx context.Context, f func()) error

func (*Pool) Waiting

func (p *Pool) Waiting() int