sync

package
v0.0.92 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2024 License: MIT Imports: 5 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdaptiveGroupOption

type AdaptiveGroupOption func(*AdaptiveWaitGroup) error

func WithSize

func WithSize(size int) AdaptiveGroupOption

WithSize sets the initial size of the waitgroup ()

type AdaptiveWaitGroup

type AdaptiveWaitGroup struct {
	Size int
	// contains filtered or unexported fields
}

func New

func New(options ...AdaptiveGroupOption) (*AdaptiveWaitGroup, error)

func (*AdaptiveWaitGroup) Add

func (s *AdaptiveWaitGroup) Add()

func (*AdaptiveWaitGroup) AddWithContext

func (s *AdaptiveWaitGroup) AddWithContext(ctx context.Context) error

func (*AdaptiveWaitGroup) Current added in v0.0.92

func (s *AdaptiveWaitGroup) Current() int

func (*AdaptiveWaitGroup) Done

func (s *AdaptiveWaitGroup) Done()

func (*AdaptiveWaitGroup) Resize

func (s *AdaptiveWaitGroup) Resize(ctx context.Context, size int) error

func (*AdaptiveWaitGroup) Wait

func (s *AdaptiveWaitGroup) Wait()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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