xsync

README

xsync

-- import "github.com/cmcoffee/snugforge/xsync"

LimitGroup is a sync.WaitGroup combined with a limiter, to limit how many threads are created.

Usage

type BitFlag

type BitFlag uint64

Atomic BitFlag

func (*BitFlag) Has

func (B *BitFlag) Has(flag uint64) bool

Check if flag is set

func (*BitFlag) Set

func (B *BitFlag) Set(flag uint64) bool

Set BitFlag

func (*BitFlag) Unset

func (B *BitFlag) Unset(flag uint64) bool

Unset BitFlag

type LimitGroup

type LimitGroup interface {
	Add(n int)
	Try() bool
	Done()
	Wait()
}

func NewLimitGroup

func NewLimitGroup(max int) LimitGroup

Documentation

Overview

LimitGroup is a sync.WaitGroup combined with a limiter, to limit how many threads are created.

Index

• type BitFlag
  • func (B *BitFlag) Has(flag uint64) bool
  • func (B *BitFlag) Set(flag uint64) bool
  • func (B *BitFlag) Unset(flag uint64) bool
• type LimitGroup
  • func NewLimitGroup(max int) LimitGroup

Types

type BitFlag

type BitFlag uint64

Atomic BitFlag

func (*BitFlag) Has

func (B *BitFlag) Has(flag uint64) bool

Check if flag is set

func (*BitFlag) Set

func (B *BitFlag) Set(flag uint64) bool

Set BitFlag

func (*BitFlag) Unset

func (B *BitFlag) Unset(flag uint64) bool

Unset BitFlag

type LimitGroup

type LimitGroup interface {
	Add(n int)
	Try() bool
	Done()
	Wait()
}

func NewLimitGroup

func NewLimitGroup(max int) LimitGroup