concurrent

Documentation

Index

• func FanOut[T any](data ttypes.IFanOut[T], number int) []T
• func RunSafe(handler func(), errHandler ...ttypes.ErrHandler)
• func WaitGroup(number int, handler ttypes.WaitGroupHandler, closeHandler ...ttypes.ErrHandler) error
• type Limit
  • func NewLimit(max int) *Limit
  • func (r *Limit) Get()
  • func (r *Limit) Put()
• type PriorityChan
  • func NewPriorityChan[T any](size int) *PriorityChan[T]
  • func (p *PriorityChan[T]) Get() T
  • func (p *PriorityChan[T]) GetWithTimeout(timeout time.Duration) (T, error)
  • func (p *PriorityChan[T]) HandleSignal(highHandler ttypes.PriorityHandler[T], lowHandler ttypes.PriorityHandler[T]) error
  • func (p *PriorityChan[T]) Put(event T, t ttypes.PriorityType)
  • func (p *PriorityChan[T]) PutWithTimeout(event T, t ttypes.PriorityType, timeout time.Duration) error
  • func (p *PriorityChan[T]) TryGet() T
  • func (p *PriorityChan[T]) TryPut(event T, t ttypes.PriorityType) error

Functions

func FanOut

func FanOut[T any](data ttypes.IFanOut[T], number int) []T

func RunSafe

func RunSafe(handler func(), errHandler ...ttypes.ErrHandler)

RunSafe 捕获panic的协程

func WaitGroup

func WaitGroup(number int, handler ttypes.WaitGroupHandler, closeHandler ...ttypes.ErrHandler) error

WaitGroup wait group封装

Types

type Limit

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

Limit 限制并发器，限制最大同时运行的数量

func NewLimit

func NewLimit(max int) *Limit

func (*Limit) Get

func (r *Limit) Get()

func (*Limit) Put

func (r *Limit) Put()

type PriorityChan

type PriorityChan[T any] struct {
	// contains filtered or unexported fields
}

func NewPriorityChan

func NewPriorityChan[T any](size int) *PriorityChan[T]

func (*PriorityChan[T]) Get

func (p *PriorityChan[T]) Get() T

Get 获取数据，阻塞等待

func (*PriorityChan[T]) GetWithTimeout

func (p *PriorityChan[T]) GetWithTimeout(timeout time.Duration) (T, error)

GetWithTimeout 获取数据，支持超时返回

func (*PriorityChan[T]) HandleSignal

func (p *PriorityChan[T]) HandleSignal(highHandler ttypes.PriorityHandler[T], lowHandler ttypes.PriorityHandler[T]) error

HandleSignal 通过传入处理函数，处理队列信号

func (*PriorityChan[T]) Put

func (p *PriorityChan[T]) Put(event T, t ttypes.PriorityType)

func (*PriorityChan[T]) PutWithTimeout

func (p *PriorityChan[T]) PutWithTimeout(event T, t ttypes.PriorityType, timeout time.Duration) error

func (*PriorityChan[T]) TryGet

func (p *PriorityChan[T]) TryGet() T

TryGet 尝试获取数据，如果没准备好直接返回

func (*PriorityChan[T]) TryPut

func (p *PriorityChan[T]) TryPut(event T, t ttypes.PriorityType) error