zq

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 17, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ZQ

type ZQ struct {
	WorkerCounter *zatomic.Int
	WorkerFn      func(any)
	JobsWg        *zwg.Zwg
	// contains filtered or unexported fields
}

func Default added in v1.0.1

func Default(fn func(any)) *ZQ

func Default12 added in v1.0.1

func Default12(fn func(any)) *ZQ

func Default16 added in v1.0.1

func Default16(fn func(any)) *ZQ

func Default2 added in v1.0.1

func Default2(fn func(any)) *ZQ

func Default24 added in v1.0.1

func Default24(fn func(any)) *ZQ

func Default32 added in v1.0.1

func Default32(fn func(any)) *ZQ

func Default4 added in v1.0.1

func Default4(fn func(any)) *ZQ

func Default48 added in v1.0.1

func Default48(fn func(any)) *ZQ

func Default6 added in v1.0.1

func Default6(fn func(any)) *ZQ

func Default64 added in v1.0.1

func Default64(fn func(any)) *ZQ

func Default8 added in v1.0.1

func Default8(fn func(any)) *ZQ

func DefaultN added in v1.0.1

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

func New

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

func (*ZQ) AddJob

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

func (*ZQ) AddWorker

func (q *ZQ) AddWorker(delta int)

func (*ZQ) Quit

func (q *ZQ) Quit()

func (*ZQ) RemoveWorker

func (q *ZQ) RemoveWorker()

func (*ZQ) Wait

func (q *ZQ) Wait()

Jump to

Keyboard shortcuts

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