concurrent

Documentation

Index

• func ErrorGroupDiff(handlers []ttypes.ErrorGroupHandler, closeHandler ...ttypes.ErrHandler) error
• func ErrorGroupLimit(n int, handlers []ttypes.ErrorGroupHandler, closeHandler ...ttypes.ErrHandler) error
• func ErrorGroupSame(number int, handler ttypes.ErrorGroupHandler, ...) error
• func FanOut[T any](data ttypes.IFanOut[T], number int) []T
• func RunSafe(handler func(), errHandler ...ttypes.ErrHandler)
• func WaitGroupDiff(handlers []ttypes.WaitGroupHandler)
• func WaitGroupLimit(n int, handlers []ttypes.WaitGroupHandler)
• func WaitGroupSame(number int, handler ttypes.WaitGroupHandler)
• type Future
  • func Run[T any](fn func() *T) *Future[T]
  • func (f *Future[T]) TryGet() (*T, bool)
• type Limit
  • func NewLimit(max int) *Limit
  • func (r *Limit) Get()
  • func (r *Limit) Put()
• type PriorityChan
  • func NewPriorityChan[T any](hsize int, lsize 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 ErrorGroupDiff

func ErrorGroupDiff(handlers []ttypes.ErrorGroupHandler, closeHandler ...ttypes.ErrHandler) error

func ErrorGroupLimit

func ErrorGroupLimit(n int, handlers []ttypes.ErrorGroupHandler, closeHandler ...ttypes.ErrHandler) error

func ErrorGroupSame

func ErrorGroupSame(number int, handler ttypes.ErrorGroupHandler, closeHandler ...ttypes.ErrHandler) error

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 WaitGroupDiff

func WaitGroupDiff(handlers []ttypes.WaitGroupHandler)

func WaitGroupLimit

func WaitGroupLimit(n int, handlers []ttypes.WaitGroupHandler)

func WaitGroupSame

func WaitGroupSame(number int, handler ttypes.WaitGroupHandler)

Types

type Future

type Future[T any] struct {
	Chan chan *T
}

func Run

func Run[T any](fn func() *T) *Future[T]

func (*Future[T]) TryGet

func (f *Future[T]) TryGet() (*T, bool)

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](hsize int, lsize 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