ants: github.com/panjf2000/ants Index | Files | Directories

package ants

import "github.com/panjf2000/ants"

Index

Package Files

ants.go pool.go pool_func.go worker.go worker_func.go

Constants

const (
    // DEFAULT_ANTS_POOL_SIZE is the default capacity for a default goroutine pool.
    DEFAULT_ANTS_POOL_SIZE = math.MaxInt32

    // DEFAULT_CLEAN_INTERVAL_TIME is the interval time to clean up goroutines.
    DEFAULT_CLEAN_INTERVAL_TIME = 1

    // CLOSED represents that the pool is closed.
    CLOSED = 1
)

Variables

var (

    // ErrInvalidPoolSize will be returned when setting a negative number as pool capacity.
    ErrInvalidPoolSize = errors.New("invalid size for pool")

    // ErrLackPoolFunc will be returned when invokers don't provide function for pool.
    ErrLackPoolFunc = errors.New("must provide function for pool")

    // ErrInvalidPoolExpiry will be returned when setting a negative number as the periodic duration to purge goroutines.
    ErrInvalidPoolExpiry = errors.New("invalid expiry for pool")

    // ErrPoolClosed will be returned when submitting task to a closed pool.
    ErrPoolClosed = errors.New("this pool has been closed")

    // ErrPoolOverload will be returned when the pool is full and no workers available.
    ErrPoolOverload = errors.New("too many goroutines blocked on submit or Nonblocking is set")
)

func Cap Uses

func Cap() int

Cap returns the capacity of this default pool.

func Free Uses

func Free() int

Free returns the available goroutines to work.

func Release Uses

func Release()

Release Closes the default pool.

func Running Uses

func Running() int

Running returns the number of the currently running goroutines.

func Submit Uses

func Submit(task func()) error

Submit submits a task to pool.

type Option Uses

type Option func(opts *Options)

func WithExpiryDuration Uses

func WithExpiryDuration(expiryDuration time.Duration) Option

func WithMaxBlockingTasks Uses

func WithMaxBlockingTasks(maxBlockingTasks int) Option

func WithNonblocking Uses

func WithNonblocking(nonblocking bool) Option

func WithOptions Uses

func WithOptions(options Options) Option

func WithPanicHandler Uses

func WithPanicHandler(panicHandler func(interface{})) Option

func WithPreAlloc Uses

func WithPreAlloc(preAlloc bool) Option

type Options Uses

type Options struct {
    // ExpiryDuration set the expired time (second) of every worker.
    ExpiryDuration time.Duration

    // PreAlloc indicate whether to make memory pre-allocation when initializing Pool.
    PreAlloc bool

    // Max number of goroutine blocking on pool.Submit.
    // 0 (default value) means no such limit.
    MaxBlockingTasks int

    // When Nonblocking is true, Pool.Submit will never be blocked.
    // ErrPoolOverload will be returned when Pool.Submit cannot be done at once.
    // When Nonblocking is true, MaxBlockingTasks is inoperative.
    Nonblocking bool

    // PanicHandler is used to handle panics from each worker goroutine.
    // if nil, panics will be thrown out again from worker goroutines.
    PanicHandler func(interface{})
}

type Pool Uses

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

Pool accept the tasks from client, it limits the total of goroutines to a given number by recycling goroutines.

func NewPool Uses

func NewPool(size int, options ...Option) (*Pool, error)

NewPool generates an instance of ants pool.

func (*Pool) Cap Uses

func (p *Pool) Cap() int

Cap returns the capacity of this pool.

func (*Pool) Free Uses

func (p *Pool) Free() int

Free returns the available goroutines to work.

func (*Pool) Release Uses

func (p *Pool) Release()

Release Closes this pool.

func (*Pool) Running Uses

func (p *Pool) Running() int

Running returns the number of the currently running goroutines.

func (*Pool) Submit Uses

func (p *Pool) Submit(task func()) error

Submit submits a task to this pool.

func (*Pool) Tune Uses

func (p *Pool) Tune(size uint)

Tune changes the capacity of this pool.

type PoolWithFunc Uses

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

PoolWithFunc accept the tasks from client, it limits the total of goroutines to a given number by recycling goroutines.

func NewPoolWithFunc Uses

func NewPoolWithFunc(size int, pf func(interface{}), options ...Option) (*PoolWithFunc, error)

NewPoolWithFunc generates an instance of ants pool with a specific function.

func (*PoolWithFunc) Cap Uses

func (p *PoolWithFunc) Cap() int

Cap returns the capacity of this pool.

func (*PoolWithFunc) Free Uses

func (p *PoolWithFunc) Free() int

Free returns a available goroutines to work.

func (*PoolWithFunc) Invoke Uses

func (p *PoolWithFunc) Invoke(args interface{}) error

Invoke submits a task to pool.

func (*PoolWithFunc) Release Uses

func (p *PoolWithFunc) Release()

Release Closed this pool.

func (*PoolWithFunc) Running Uses

func (p *PoolWithFunc) Running() int

Running returns the number of the currently running goroutines.

func (*PoolWithFunc) Tune Uses

func (p *PoolWithFunc) Tune(size int)

Tune change the capacity of this pool.

Directories

PathSynopsis
examples

Package ants imports 7 packages (graph) and is imported by 4 packages. Updated 2019-08-23. Refresh now. Tools for package owners.