base

Documentation

Index

• type Node
• type Queue
  • func (q *Queue) Empty() bool
  • func (q *Queue) Pop() exec.Task
  • func (q *Queue) Process()
  • func (q *Queue) Push(task exec.Task)
  • func (q *Queue) Swap(o *Queue)
• type Worker
  • func NewWorker() *Worker
  • func (w *Worker) Post(task exec.Task)
  • func (w *Worker) Start(wg *sync.WaitGroup)
  • func (w *Worker) Stop()

Types

type Node

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

type Queue

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

双向非循环队列

func (*Queue) Empty

func (q *Queue) Empty() bool

func (*Queue) Pop

func (q *Queue) Pop() exec.Task

func (*Queue) Process

func (q *Queue) Process()

func (*Queue) Push

func (q *Queue) Push(task exec.Task)

func (*Queue) Swap

func (q *Queue) Swap(o *Queue)

type Worker

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

func NewWorker

func NewWorker() *Worker

func (*Worker) Post

func (w *Worker) Post(task exec.Task)

func (*Worker) Start

func (w *Worker) Start(wg *sync.WaitGroup)

func (*Worker) Stop

func (w *Worker) Stop()