routinepool

package

v0.2.3 Latest Latest Go to latest Published: Sep 1, 2015 License: MIT Imports: 2 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

Repository

github.com/cosiner/gohper

Links

Open Source Insights

Documentation ¶

Index ¶

type Job
type Pool
- func New(processor func(Job), jobBufsize int, maxIdle, maxActive uint64) *Pool

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Job ¶

type Job interface{}

type Pool ¶

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

func New ¶

func New(processor func(Job), jobBufsize int, maxIdle, maxActive uint64) *Pool

New create a pool with fix number of goroutine, if maxActive is 0, there is no limit of goroutine number

func (*Pool) Close ¶

func (p *Pool) Close()

Close stop receive new job, and waiting for all exists jobs to be processed

func (*Pool) Do ¶

func (p *Pool) Do(job Job) bool

Do process a job. If there is no goroutine available and goroutine number already reach the limitation, it will blocked untile a goroutine is free. Otherwise create a new goroutine. Return false only if pool already closed

func (*Pool) Info ¶

func (p *Pool) Info() (numIdle, numActive uint64)

Info return current infomation about idle and activing goroutine number of the pool

Source Files ¶

View all Source files

pool.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL