The highest tagged major version is v2.

grpool

package

v1.8.3 Latest Latest Go to latest Published: Jul 28, 2019 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package grpool implements a goroutine reusable pool.

This section is empty.

This section is empty.

func Add(f func()) error

Add pushes a new job to the pool using default goroutine pool. The job will be executed asynchronously.

func Jobs() int

Jobs returns current job count of default goroutine pool.

func Size() int

Size returns current goroutine count of default goroutine pool.

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

Goroutine Pool

func New(limit ...int) *Pool

New creates and returns a new goroutine pool object. The parameter <limit> is used to limit the max goroutine count, which is not limited in default.

func (p *Pool) Add(f func()) error

Add pushes a new job to the pool. The job will be executed asynchronously.

func (p *Pool) Cap() int

Cap returns the capacity of the pool. This capacity is defined when pool is created. If it returns -1 means no limit.

func (p *Pool) Close()

Close closes the goroutine pool, which makes all goroutines exit.

func (p *Pool) IsClosed() bool

IsClosed returns if pool is closed.

func (p *Pool) Jobs() int

Jobs returns current job count of the pool.

func (p *Pool) Size() int

Size returns current goroutine count of the pool.