sync_queue

Documentation

Index

• type CancelContext
• type Limiter
  • func NewLimiter(limit int64) *Limiter
  • func (p *Limiter) Add()
  • func (p *Limiter) Cancel(id int64)
  • func (p *Limiter) Close(id int64)
  • func (p *Limiter) Context(id int64) context.Context
  • func (p *Limiter) Done()
  • func (p *Limiter) Open(id int64) bool

Types

type CancelContext

type CancelContext struct {
	Ctx    context.Context
	Cancel context.CancelFunc
}

type Limiter

type Limiter struct {
	SLock    sync.Mutex
	LimitMap map[int64]bool
	LimitNum chan bool

	CanCtxList map[int64]*CancelContext
	// contains filtered or unexported fields
}

func NewLimiter

func NewLimiter(limit int64) *Limiter

func (*Limiter) Add

func (p *Limiter) Add()

func (*Limiter) Cancel

func (p *Limiter) Cancel(id int64)

func (*Limiter) Close

func (p *Limiter) Close(id int64)

func (*Limiter) Context

func (p *Limiter) Context(id int64) context.Context

func (*Limiter) Done

func (p *Limiter) Done()

func (*Limiter) Open

func (p *Limiter) Open(id int64) bool

* Open|Close Used to restrict the execution of programs with the same ID, only one program with the same ID can be executed at a time *