parallelwalk

Documentation

Index

• func NewParallelWalk[Job, State any](concurrency int) jobwalker.JobWalker[Job, State]

Functions

func NewParallelWalk

func NewParallelWalk[Job, State any](concurrency int) jobwalker.JobWalker[Job, State]

NewParallelWalk generates a function to handle a series of jobs that may spawn more jobs It will execute jobs in parallel, with the specified concurrency until all initial jobs and all spawned jobs (recursively) are handled, or a job errors This code is adapted from https://github.com/ipfs/go-merkledag/blob/master/merkledag.go#L464C6-L584