Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrContention = errors.New("contention")
)
Functions ¶
This section is empty.
Types ¶
type PriorityQueue ¶
type PriorityQueue struct {
Queues []chan interface{}
// contains filtered or unexported fields
}
PriorityQueue是基本结构
func (*PriorityQueue) Push ¶
func (pq *PriorityQueue) Push(x interface{}, p int) error
push将项目推送到priority参数中指定的适当队列 如果给定了上下文，它将一直等到推送该项或上下文中止为止。
func (*PriorityQueue) Run ¶
func (pq *PriorityQueue) Run(ctx context.Context, f func(interface{}))
运行是从队列中弹出项目的永久循环
Source Files
Click to show internal directories.
Click to hide internal directories.