pr

package module

v0.0.0-...-adb0578 Latest Latest Go to latest Published: Sep 2, 2022 License: MIT Imports: 11 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/reusee/pr

Links

Open Source Insights

README ¶

pr

parallel utils

Documentation ¶

Index ¶

func Consume[T any](parentWt *WaitTree, numThread int, fn func(threadID int, value T) error, ...) (put Put[T], wait Wait)
type BackgroundCtx
- func (_ BackgroundCtx) IsWaitTreeOption()
type BacklogSize
- func (_ BacklogSize) IsConsumeOption()
type ConsumeOption
type ID
- func (_ ID) IsWaitTreeOption()
type Pool
- func NewPool[T any](capacity int32, newFunc func() T) *Pool[T]
- func (p *Pool[T]) Get() (value T, put func() bool)
- func (p *Pool[T]) GetRC() (value T, put func() bool, incRef func())
- func (p *Pool[T]) Getter() (get func() T, putAll func())
type Put
type Timeout
- func (_ Timeout) IsWaitTreeOption()
type Trace
- func (_ Trace) IsWaitTreeOption()
type Wait
type WaitTree
- func NewRootWaitTree(options ...WaitTreeOption) *WaitTree
- func NewWaitTree(parent *WaitTree, options ...WaitTreeOption) *WaitTree
- func (t *WaitTree) Add() (done func())
- func (t *WaitTree) Go(fn func())
- func (t *WaitTree) PrintTraces(w io.Writer)
- func (t *WaitTree) Wait()
type WaitTreeOption

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Consume ¶

func Consume[T any](
	parentWt *WaitTree,
	numThread int,
	fn func(threadID int, value T) error,
	options ...ConsumeOption,
) (
	put Put[T],
	wait Wait,
)

Types ¶

type BackgroundCtx ¶

type BackgroundCtx func() context.Context

func (BackgroundCtx) IsWaitTreeOption ¶

func (_ BackgroundCtx) IsWaitTreeOption()

type BacklogSize ¶

type BacklogSize int

func (BacklogSize) IsConsumeOption ¶

func (_ BacklogSize) IsConsumeOption()

type ConsumeOption ¶

type ConsumeOption interface {
	IsConsumeOption()
}

type ID ¶

type ID string

func (ID) IsWaitTreeOption ¶

func (_ ID) IsWaitTreeOption()

type Pool ¶

type Pool[T any] struct {
	Callers [][]byte

	LogCallers bool
	// contains filtered or unexported fields
}

func NewPool ¶

func NewPool[T any](
	capacity int32,
	newFunc func() T,
) *Pool[T]

func (*Pool[T]) Get ¶

func (p *Pool[T]) Get() (value T, put func() bool)

func (*Pool[T]) GetRC ¶

func (p *Pool[T]) GetRC() (
	value T,
	put func() bool,
	incRef func(),
)

func (*Pool[T]) Getter ¶

func (p *Pool[T]) Getter() (
	get func() T,
	putAll func(),
)

type Put ¶

type Put[T any] func(T) bool

type Timeout ¶

type Timeout time.Duration

func (Timeout) IsWaitTreeOption ¶

func (_ Timeout) IsWaitTreeOption()

type Trace ¶

type Trace bool

func (Trace) IsWaitTreeOption ¶

func (_ Trace) IsWaitTreeOption()

type Wait ¶

type Wait = func(noMorePut bool) error

type WaitTree ¶

type WaitTree struct {
	ID     string
	Ctx    context.Context
	Cancel func()
	// contains filtered or unexported fields
}

func NewRootWaitTree ¶

func NewRootWaitTree(
	options ...WaitTreeOption,
) *WaitTree

func NewWaitTree ¶

func NewWaitTree(
	parent *WaitTree,
	options ...WaitTreeOption,
) *WaitTree

func (*WaitTree) Add ¶

func (t *WaitTree) Add() (done func())

func (*WaitTree) Go ¶

func (t *WaitTree) Go(fn func())

func (*WaitTree) PrintTraces ¶

func (t *WaitTree) PrintTraces(w io.Writer)

func (*WaitTree) Wait ¶

func (t *WaitTree) Wait()

type WaitTreeOption ¶

type WaitTreeOption interface {
	IsWaitTreeOption()
}

Source Files ¶

View all Source files

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