semaphore

Documentation

Index

• Constants
• func EmptyTime() time.Time
• func GetMaxSimultaneous() int
• func NewContext(parent context.Context, timeout time.Duration, deadline time.Time) (ctx context.Context, cancel context.CancelFunc)
• type FuncContext
• type Sem
  • func NewSemaphore(maxSimultaneous int) Sem
  • func NewSemaphoreWithContext(ctx context.Context, maxSimultaneous int) Sem
• type SemBar

Constants

const (
	ErrorParamEmpty liberr.CodeError = iota + liberr.MinPkgSemaphore
	ErrorWorkerNew
	ErrorWorkerWaitAll
)

Functions

func EmptyTime

func EmptyTime() time.Time

func GetMaxSimultaneous

func GetMaxSimultaneous() int

func NewContext

func NewContext(parent context.Context, timeout time.Duration, deadline time.Time) (ctx context.Context, cancel context.CancelFunc)

Types

type FuncContext

type FuncContext func() context.Context

type Sem

type Sem interface {
	NewWorker() liberr.Error
	NewWorkerTry() bool
	DeferWorker()
	DeferMain()

	WaitAll() liberr.Error
}

func NewSemaphore

func NewSemaphore(maxSimultaneous int) Sem

Deprecated: func without context will be deprecated

func NewSemaphoreWithContext

func NewSemaphoreWithContext(ctx context.Context, maxSimultaneous int) Sem

type SemBar

type SemBar interface {
	Sem

	Current() int64
	Completed() bool
	Reset(total, current int64)
	ResetDefined(current int64)
	Done()

	Increment(n int)
	Increment64(n int64)
}