zq

Documentation

Index

• type ZQ
  • func Default(fn func(int, any)) *ZQ
  • func Default12(fn func(int, any)) *ZQ
  • func Default16(fn func(int, any)) *ZQ
  • func Default2(fn func(int, any)) *ZQ
  • func Default24(fn func(int, any)) *ZQ
  • func Default32(fn func(int, any)) *ZQ
  • func Default4(fn func(int, any)) *ZQ
  • func Default48(fn func(int, any)) *ZQ
  • func Default6(fn func(int, any)) *ZQ
  • func Default64(fn func(int, any)) *ZQ
  • func Default8(fn func(int, any)) *ZQ
  • func DefaultN(qtyWorkers int, fn func(int, any)) *ZQ
  • func New(qtyWorkers int, buff int, fn func(int, any)) *ZQ
  • func (q *ZQ) AddJob(a any) error
  • func (q *ZQ) AddJobForce(a any) error
  • func (q *ZQ) AddWorker(delta int)
  • func (q *ZQ) MustJob(a any)
  • func (q *ZQ) Quit()
  • func (q *ZQ) RemoveWorker()
  • func (q *ZQ) Wait()
  • func (q *ZQ) WithZQuit(quit *zquit.ZQuit) *ZQ

Types

type ZQ

type ZQ struct {
	WorkerCounter *zatomic.Int
	WorkerFn      func(int, any)
	ZQuit         *zquit.ZQuit
	Jobs          chan any
	// contains filtered or unexported fields
}

func Default

func Default(fn func(int, any)) *ZQ

func Default12

func Default12(fn func(int, any)) *ZQ

func Default16

func Default16(fn func(int, any)) *ZQ

func Default2

func Default2(fn func(int, any)) *ZQ

func Default24

func Default24(fn func(int, any)) *ZQ

func Default32

func Default32(fn func(int, any)) *ZQ

func Default4

func Default4(fn func(int, any)) *ZQ

func Default48

func Default48(fn func(int, any)) *ZQ

func Default6

func Default6(fn func(int, any)) *ZQ

func Default64

func Default64(fn func(int, any)) *ZQ

func Default8

func Default8(fn func(int, any)) *ZQ

func DefaultN

func DefaultN(qtyWorkers int, fn func(int, any)) *ZQ

func New

func New(qtyWorkers int, buff int, fn func(int, any)) *ZQ

func (*ZQ) AddJob

func (q *ZQ) AddJob(a any) error

func (*ZQ) AddJobForce

func (q *ZQ) AddJobForce(a any) error

func (*ZQ) AddWorker

func (q *ZQ) AddWorker(delta int)

func (*ZQ) MustJob

func (q *ZQ) MustJob(a any)

func (*ZQ) Quit

func (q *ZQ) Quit()

func (*ZQ) RemoveWorker

func (q *ZQ) RemoveWorker()

func (*ZQ) Wait

func (q *ZQ) Wait()

func (*ZQ) WithZQuit

func (q *ZQ) WithZQuit(quit *zquit.ZQuit) *ZQ