semaphore

Documentation

Index

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

Constants

const (
	EMPTY_PARAMS errors.CodeError = iota + errors.MIN_PKG_Semaphore
	NEW_WORKER
	WAITALL
)

Functions

func GetContext

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

func GetEmptyTime

func GetEmptyTime() time.Time

func GetMaxSimultaneous

func GetMaxSimultaneous() int

func IsCodeError

func IsCodeError() bool

Types

type Sem

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

	WaitAll() Error
	Context() context.Context
	Cancel()
}

func NewSemaphore

func NewSemaphore(maxSimultaneous int, timeout time.Duration, deadline time.Time, parent context.Context) Sem