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
- type PriorityChan
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 限制并发器，限制最大同时运行的数量
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]) 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]) TryPut ¶
func (p *PriorityChan[T]) TryPut(event T, t ttypes.PriorityType) error
Source Files
Click to show internal directories.
Click to hide internal directories.