mtx

Documentation

Index

• type TimeoutSemaphore
  • func NewTimeoutSemaphore(maxCount int64) *TimeoutSemaphore
  • func (ts *TimeoutSemaphore) AcquireWithAutoRelease(ctx context.Context, weight int64, timeout time.Duration, id uint64, ...) error
  • func (ts *TimeoutSemaphore) Release(id uint64, weight int64)

Types

type TimeoutSemaphore

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

func NewTimeoutSemaphore

func NewTimeoutSemaphore(maxCount int64) *TimeoutSemaphore

func (*TimeoutSemaphore) AcquireWithAutoRelease

func (ts *TimeoutSemaphore) AcquireWithAutoRelease(ctx context.Context, weight int64, timeout time.Duration, id uint64,
	fnTimeoutCallback func(id uint64)) error

func (*TimeoutSemaphore) Release

func (ts *TimeoutSemaphore) Release(id uint64, weight int64)