semaphore

Documentation

Index

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

Constants

const (
	ErrorParamsEmpty errors.CodeError = iota + errors.MIN_PKG_Semaphore
	ErrorWorkerNew
	ErrorWorkerWaitAll
)

Functions

func EmptyTime

func EmptyTime() time.Time

func GetMaxSimultaneous

func GetMaxSimultaneous() int

func IsCodeError

func IsCodeError() bool

func NewContext

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

Types

type Sem

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

	WaitAll() errors.Error
}

func NewSemaphore

func NewSemaphore(maxSimultaneous int) Sem

func NewSemaphoreWithContext

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