worker

Documentation

Index

• type Conf
• type Pool
  • func New(conf *Conf) (w *Pool)
  • func (w *Pool) Add(f func()) error
  • func (w *Pool) Close()
  • func (w *Pool) Wait()

Types

type Conf

type Conf struct {
	QueueSize     int
	WorkerProcMax int
	WorkerNumber  int
}

Conf .

type Pool

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

Pool .

func New

func New(conf *Conf) (w *Pool)

New .

func (*Pool) Add

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

Add .

func (*Pool) Close

func (w *Pool) Close()

Close .

func (*Pool) Wait

func (w *Pool) Wait()

Wait .