taskqueue

package

v22.11.0 Latest Latest Go to latest Published: Dec 2, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func CreateTaskQueue(size uint) *TaskQueue

func (e *TaskQueue) Drain()

Return when taskqueue is empty

func (e *TaskQueue) Length() uint

Return current size of task queue

func (e *TaskQueue) Push(f func() (interface{}, fail.Error), timeout time.Duration) (interface{}, fail.Error)

Add a task todo in taskqueue

func (e *TaskQueue) Size() uint

Return max size of task queue

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