grpool

Documentation

Overview

Package grpool implements a goroutine reusable pool.

Index

• func Add(f func())
• func Jobs() int
• func Size() int
• type Pool
  • func New(limit ...int) *Pool
  • func (p *Pool) Add(f func())
  • func (p *Pool) Close()
  • func (p *Pool) Jobs() int
  • func (p *Pool) Size() int

Functions

func Add

func Add(f func())

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

func Jobs

func Jobs() int

Jobs returns current job count of default goroutine pool.

func Size

func Size() int

Size returns current goroutine count of default goroutine pool.

Types

type Pool

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

Goroutine Pool

func New

func New(limit ...int) *Pool

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

func (*Pool) Add

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

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

func (*Pool) Close

func (p *Pool) Close()

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

func (*Pool) Jobs

func (p *Pool) Jobs() int

Jobs returns current job count of the pool.

func (*Pool) Size

func (p *Pool) Size() int

Size returns current goroutine count of the pool.