pool

Documentation

Index

• type GroutingPool
  • func (this *GroutingPool) Init(total int, limit time.Duration) *GroutingPool
  • func (this *GroutingPool) Next()
  • func (this *GroutingPool) Remand()
• type PrefixMutex
  • func (this *PrefixMutex) Init(clearSeconds int) *PrefixMutex
  • func (this *PrefixMutex) Lock(prefix string)
  • func (this *PrefixMutex) UnLock(prefix string)

Types

type GroutingPool

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

协程池 @author fuzeyu

func (*GroutingPool) Init

func (this *GroutingPool) Init(total int, limit time.Duration) *GroutingPool

初始化 @param total 协程池总长度 @param limit 下次分发协程的间隔时间

func (*GroutingPool) Next

func (this *GroutingPool) Next()

获取下一次协程池

func (*GroutingPool) Remand

func (this *GroutingPool) Remand()

归还协程

type PrefixMutex

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

自定义线程锁 @author fuzeyu

func (*PrefixMutex) Init

func (this *PrefixMutex) Init(clearSeconds int) *PrefixMutex

初始化 @param clearSeconds 锁的清理时间

func (*PrefixMutex) Lock

func (this *PrefixMutex) Lock(prefix string)

获取锁 @param prefix 锁内容

func (*PrefixMutex) UnLock

func (this *PrefixMutex) UnLock(prefix string)

解锁 @param prefix 锁内容