worker

package

v0.0.1 Latest Latest Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 10 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/15mga/kiwi

Links

Open Source Insights

Documentation ¶

Index ¶

func Active() *active
func FnvBytes(bytes []byte) int64
func FnvInt64(v int64) int64
func FnvStr(key string) int64
func Global() *global
func Go(fn util.FnAnySlc, params ...any)
func InitActive(opts ...ActiveOption)
func InitGlobal()
func InitParallel()
func InitShare()
func MemHash(data []byte) int64
func MemHashString(str string) int64
func NewGlobal() *global
func P[DT any](data []DT, fn func(DT))
func PFn(fns []util.FnAnySlc, params ...any)
func PParams[DT any](data []DT, fn func(DT, []any), params ...any)
func PParamsToFnLink[DT any](data []DT, fn func(DT, []any, *ds.FnLink), params ...any)
func PParamsToToLink[InT, OutT any](data []InT, fn func(InT, []any, *ds.Link[OutT]), pcr func(*ds.Link[OutT]), ...)
func PTo[DT1, DT2 any](data []DT1, fn func(DT1) DT2, complete func([]DT2))
func PToFnLink[DT any](data []DT, fn func(DT, *ds.FnLink))
func PToLink[InT, OutT any](data []InT, fn func(InT, *ds.Link[OutT]), pcr func(*ds.Link[OutT]))
func PushPJob(job IJob)
func RecycleJob(job *Job)
func Self(fn util.FnAnySlc, params ...any)
func Share() *fnShare
type ActiveOption
- func ActiveCap(cap int) ActiveOption
- func ActiveTickSecs(seconds int64) ActiveOption
type FnJob
type FnJobData
type FnWorker
- func NewFnWorker() *FnWorker
- func (w *FnWorker) Push(fn util.FnAnySlc, params ...any)
type IJob
type Job
- func SpawnJob() *Job
type JobName
type JobWorker
- func NewJobWorker(fn FnJob) *JobWorker
- func (w *JobWorker) Push(name JobName, data ...any)
type Worker
- func NewWorker[T any](fn func(T)) *Worker[T]
- func (w *Worker[T]) Dispose()
- func (w *Worker[T]) Push(item T)
- func (w *Worker[T]) Start()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Active ¶

func Active() *active

func FnvBytes ¶

func FnvBytes(bytes []byte) int64

func FnvInt64 ¶

func FnvInt64(v int64) int64

func FnvStr ¶

func FnvStr(key string) int64

func Global ¶

func Global() *global

func Go ¶

func Go(fn util.FnAnySlc, params ...any)

func InitActive ¶

func InitActive(opts ...ActiveOption)

func InitGlobal ¶

func InitGlobal()

func InitParallel ¶

func InitParallel()

func InitShare ¶

func InitShare()

func MemHash ¶

func MemHash(data []byte) int64

func MemHashString ¶

func MemHashString(str string) int64

func NewGlobal ¶

func NewGlobal() *global

func P ¶

func P[DT any](data []DT, fn func(DT))

func PFn ¶

func PFn(fns []util.FnAnySlc, params ...any)

func PParams ¶

func PParams[DT any](data []DT, fn func(DT, []any), params ...any)

func PParamsToFnLink ¶

func PParamsToFnLink[DT any](data []DT, fn func(DT, []any, *ds.FnLink), params ...any)

func PParamsToToLink ¶

func PParamsToToLink[InT, OutT any](data []InT, fn func(InT, []any, *ds.Link[OutT]),
	pcr func(*ds.Link[OutT]), params ...any)

func PTo ¶

func PTo[DT1, DT2 any](data []DT1, fn func(DT1) DT2, complete func([]DT2))

func PToFnLink ¶

func PToFnLink[DT any](data []DT, fn func(DT, *ds.FnLink))

func PToLink ¶

func PToLink[InT, OutT any](data []InT, fn func(InT, *ds.Link[OutT]),
	pcr func(*ds.Link[OutT]))

func PushPJob ¶

func PushPJob(job IJob)

func RecycleJob ¶

func RecycleJob(job *Job)

func Self ¶

func Self(fn util.FnAnySlc, params ...any)

func Share() *fnShare

Types ¶

type ActiveOption ¶

type ActiveOption func(o *activeOption)

func ActiveCap ¶

func ActiveCap(cap int) ActiveOption

ActiveCap 设置活跃初始容量

func ActiveTickSecs ¶

func ActiveTickSecs(seconds int64) ActiveOption

ActiveTickSecs 设置活跃的检测间隔时间

type FnJob ¶

type FnJob func(*Job)

type FnJobData ¶

type FnJobData struct {
	Fn     util.FnAnySlc
	Params []any
}

type FnWorker ¶

type FnWorker struct {
	*Worker[FnJobData]
}

func NewFnWorker ¶

func NewFnWorker() *FnWorker

func (*FnWorker) Push ¶

func (w *FnWorker) Push(fn util.FnAnySlc, params ...any)

type IJob ¶

type IJob interface {
	Do()
}

type Job ¶

type Job struct {
	Name JobName
	Data []any
}

func SpawnJob ¶

func SpawnJob() *Job

type JobName ¶

type JobName = string

type JobWorker ¶

type JobWorker struct {
	*Worker[*Job]
	// contains filtered or unexported fields
}

func NewJobWorker ¶

func NewJobWorker(fn FnJob) *JobWorker

func (*JobWorker) Push ¶

func (w *JobWorker) Push(name JobName, data ...any)

type Worker ¶

type Worker[T any] struct {
	// contains filtered or unexported fields
}

func NewWorker ¶

func NewWorker[T any](fn func(T)) *Worker[T]

func (*Worker[T]) Dispose ¶

func (w *Worker[T]) Dispose()

func (*Worker[T]) Push ¶

func (w *Worker[T]) Push(item T)

func (*Worker[T]) Start ¶

func (w *Worker[T]) Start()

Source Files ¶

View all Source files

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

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func Active ¶

func FnvBytes ¶

func FnvInt64 ¶

func FnvStr ¶

func Global ¶

func Go ¶

func InitActive ¶

func InitGlobal ¶

func InitParallel ¶

func InitShare ¶

func MemHash ¶

func MemHashString ¶

func NewGlobal ¶

func P ¶

func PFn ¶

func PParams ¶

func PParamsToFnLink ¶

func PParamsToToLink ¶

func PTo ¶

func PToFnLink ¶

func PToLink ¶

func PushPJob ¶

func RecycleJob ¶

func Self ¶

func Share ¶

Types ¶

type ActiveOption ¶

func ActiveCap ¶

func ActiveTickSecs ¶

type FnJob ¶

type FnJobData ¶

type FnWorker ¶

func NewFnWorker ¶

func (*FnWorker) Push ¶

type IJob ¶

type Job ¶

func SpawnJob ¶

type JobName ¶

type JobWorker ¶

func NewJobWorker ¶

func (*JobWorker) Push ¶

type Worker ¶

func NewWorker ¶

func (*Worker[T]) Dispose ¶

func (*Worker[T]) Push ¶

func (*Worker[T]) Start ¶

Source Files ¶