semerrgroup

package
v0.182.0 Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2020 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package semerrgroup wraps a error group with a semaphore with configurable size, so you can control the number of tasks being executed simultaneously.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Group

type Group interface {
	Go(func() error)
	Wait() error
}

Group is the Semphore ErrorGroup itself.

func New

func New(size int) Group

New returns a new Group of a given size.

func NewSkipAware added in v0.160.0

func NewSkipAware(g Group) Group

NewSkipAware returns a new Group of a given size and aware of pipe skips.

Jump to

Keyboard shortcuts

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