poolwait

package
v0.0.0-...-8e6cb86 Latest Latest
Warning

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

Go to latest
Published: Feb 1, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ContextWithForegroundWaitGroup

func ContextWithForegroundWaitGroup(ctx context.Context) (context.Context, *worker.WaitGroup)

func Wait

func Wait(ctx context.Context, name string, pool *worker.Pool, deps *worker.WaitGroup, plain bool) error

Types

type GCWaitGroup

type GCWaitGroup struct {
	Deps *worker.WaitGroup
}

GCWaitGroup allows to depend on other Job/Worker without keeping them in memory, allowing GC to work

func ForegroundWaitGroup

func ForegroundWaitGroup(ctx context.Context) *GCWaitGroup

func (*GCWaitGroup) Add

func (wwg *GCWaitGroup) Add(j *worker.Job)

func (*GCWaitGroup) AddChild

func (wwg *GCWaitGroup) AddChild(wg *worker.WaitGroup)

Jump to

Keyboard shortcuts

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