Task ring buffer

ring.go

// TaskRing is an efficient, gob-compatible ring buffer for Tasks.
// TaskRing always wastes one element.
type TaskRing struct {
	...
	Stats Stats
}

// Stats represents the statistics of the task ring buffer.
type Stats struct {
	Deque  uint64 // Deque represents the total nubmer of dequeued tasks.
	Enque  uint64 // Enque represents the total nubmer of enqued tasks.
	...
}

// Enque enqueues a task in the ring buffer.
func (r *TaskRing) Enque(t Task) {...}
// Deque dequeues a task from the ring.
func (r *TaskRing) Deque() (t Task, ok bool) {...}