pool

Documentation

Index

• type Pool
  • func New(worker, size int) *Pool
  • func (c *Pool) Close() error
  • func (c *Pool) Do(f func()) (err error)

Types

type Pool

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

Pool sync consume data from chan

func New

func New(worker, size int) *Pool

New new a pool struct.

func (*Pool) Close

func (c *Pool) Close() error

func (*Pool) Do

func (c *Pool) Do(f func()) (err error)