firewall

Documentation

Index

• type ChanSemaphore
  • func NewChanSemaphore(cap int) *ChanSemaphore
  • func (this *ChanSemaphore) Acquire()
  • func (this *ChanSemaphore) Release()
• type Semaphore
  • func NewSemaphore(cap int) Semaphore
• type SleepLimiter
  • func NewSleepLimiter(ttl time.Duration, limit int) *SleepLimiter
  • func (this *SleepLimiter) Acquire()

Types

type ChanSemaphore

type ChanSemaphore struct {
	// contains filtered or unexported fields
}

Semaphore 限制同一时刻，最多可以发生的次数

func NewChanSemaphore

func NewChanSemaphore(cap int) *ChanSemaphore

NewChanSemaphore

func (*ChanSemaphore) Acquire

func (this *ChanSemaphore) Acquire()

func (*ChanSemaphore) Release

func (this *ChanSemaphore) Release()

type Semaphore

type Semaphore interface {
	// P wait()
	Acquire()

	// V signal()
	Release()
}

func NewSemaphore

func NewSemaphore(cap int) Semaphore

NewSemaphore

type SleepLimiter

type SleepLimiter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

SleepLimiter 限制单位时间内的可执行次数

func NewSleepLimiter

func NewSleepLimiter(ttl time.Duration, limit int) *SleepLimiter

func (*SleepLimiter) Acquire

func (this *SleepLimiter) Acquire()