Documentation
¶
Index ¶
Constants ¶
View Source
const ( PriorityCleanup = 100 // Highest - cleanup operations PriorityDelete = 50 // High - delete operations PriorityNormal = 25 // Medium - normal operations PriorityTicker = 10 // Low - ticker operations )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PriorityQueue ¶
type PriorityQueue []*WorkItem
func (PriorityQueue) Len ¶
func (pq PriorityQueue) Len() int
func (PriorityQueue) Less ¶
func (pq PriorityQueue) Less(i, j int) bool
func (*PriorityQueue) Pop ¶
func (pq *PriorityQueue) Pop() interface{}
func (*PriorityQueue) Push ¶
func (pq *PriorityQueue) Push(x interface{})
func (PriorityQueue) Swap ¶
func (pq PriorityQueue) Swap(i, j int)
type PriorityWorkerQueue ¶
type PriorityWorkerQueue struct {
// contains filtered or unexported fields
}
func NewPriorityWorkerQueue ¶
func NewPriorityWorkerQueue(poolSize int) *PriorityWorkerQueue
func (*PriorityWorkerQueue) Start ¶
func (pwq *PriorityWorkerQueue) Start()
func (*PriorityWorkerQueue) Stop ¶
func (pwq *PriorityWorkerQueue) Stop()
func (*PriorityWorkerQueue) Submit ¶
func (pwq *PriorityWorkerQueue) Submit(workType WorkType, priority int, action func())
Source Files
Click to show internal directories.
Click to hide internal directories.