Documentation
¶
Index ¶
- type FifoQueue
- type MultiTaskTicker
- func (mtt *MultiTaskTicker) AddTask(params ...interface{}) *MultiTaskTicker
- func (mtt *MultiTaskTicker) GetNumWorkers() int
- func (mtt *MultiTaskTicker) IsStarted() bool
- func (mtt *MultiTaskTicker) SetNumWorkers(nWorkers int) *MultiTaskTicker
- func (mtt *MultiTaskTicker) SetPeriod(period time.Duration) *MultiTaskTicker
- func (mtt *MultiTaskTicker) SetTasks(params ...interface{}) *MultiTaskTicker
- func (mtt *MultiTaskTicker) Start(ctx context.Context, f MultiTaskTickerFunc) (err error)
- func (mtt *MultiTaskTicker) Stop(ctx context.Context) (err error)
- func (mtt *MultiTaskTicker) StopWait()
- type MultiTaskTickerFunc
- type TaskQueue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FifoQueue ¶
type FifoQueue struct {
// contains filtered or unexported fields
}
func NewFifoQueue ¶
func NewFifoQueue() *FifoQueue
type MultiTaskTicker ¶
type MultiTaskTicker struct {
// contains filtered or unexported fields
}
func NewMultiTaskTicker ¶
func NewMultiTaskTicker() *MultiTaskTicker
func (*MultiTaskTicker) AddTask ¶
func (mtt *MultiTaskTicker) AddTask(params ...interface{}) *MultiTaskTicker
func (*MultiTaskTicker) GetNumWorkers ¶
func (mtt *MultiTaskTicker) GetNumWorkers() int
func (*MultiTaskTicker) IsStarted ¶
func (mtt *MultiTaskTicker) IsStarted() bool
func (*MultiTaskTicker) SetNumWorkers ¶
func (mtt *MultiTaskTicker) SetNumWorkers(nWorkers int) *MultiTaskTicker
func (*MultiTaskTicker) SetPeriod ¶
func (mtt *MultiTaskTicker) SetPeriod(period time.Duration) *MultiTaskTicker
func (*MultiTaskTicker) SetTasks ¶
func (mtt *MultiTaskTicker) SetTasks(params ...interface{}) *MultiTaskTicker
func (*MultiTaskTicker) Start ¶
func (mtt *MultiTaskTicker) Start(ctx context.Context, f MultiTaskTickerFunc) (err error)
func (*MultiTaskTicker) StopWait ¶
func (mtt *MultiTaskTicker) StopWait()
type MultiTaskTickerFunc ¶
type TaskQueue ¶
type TaskQueue struct {
// contains filtered or unexported fields
}
*
- Task Queue: it is used to help us schedule a
- sequence of executions *
- The default num workers is 1
- If this number is 1, it could also treated as a
- strict FIFO Queue *
func NewTaskQueue ¶
func NewTaskQueue() *TaskQueue
func (*TaskQueue) Close ¶
func (q *TaskQueue) Close()
It's OK to leave a Go channel open forever and never close it. When the channel is no longer used, it will be garbage collected. -- <https://stackoverflow.com/questions/8593645> However we could provide a close + wait interface, which is used to indicate its finishing
func (*TaskQueue) GetNumWorkers ¶
func (*TaskQueue) SetNumWorkers ¶
Click to show internal directories.
Click to hide internal directories.