Versions in this module Expand all Collapse all v0 v0.0.1 Mar 12, 2024 Changes in this version + 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 PFn(fns []util.FnAnySlc, 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 PParams[DT any](data []DT, fn func(DT, []any), params ...any) + 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 PTo[DT1, DT2 any](data []DT1, fn func(DT1) DT2, complete func([]DT2)) + func P[DT any](data []DT, fn func(DT)) + func PushPJob(job IJob) + func RecycleJob(job *Job) + func Self(fn util.FnAnySlc, params ...any) + func Share() *fnShare + type ActiveOption func(o *activeOption) + func ActiveCap(cap int) ActiveOption + func ActiveTickSecs(seconds int64) ActiveOption + type FnJob func(*Job) + type FnJobData struct + Fn util.FnAnySlc + Params []any + type FnWorker struct + func NewFnWorker() *FnWorker + func (w *FnWorker) Push(fn util.FnAnySlc, params ...any) + type IJob interface + Do func() + type Job struct + Data []any + Name JobName + func SpawnJob() *Job + type JobName = string + type JobWorker struct + func NewJobWorker(fn FnJob) *JobWorker + func (w *JobWorker) Push(name JobName, data ...any) + type Worker struct + 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()