njs_semaphore

Documentation

Index

• func GetMaxSimultaneous() int
• type Sem
  • func NewSemaphore(maxSimultaneous int, timeout time.Duration, deadline time.Time, ...) Sem

Functions

func GetMaxSimultaneous

func GetMaxSimultaneous() int

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