Versions in this module Expand all Collapse all v0 v0.2.1 May 5, 2015 Changes in this version + var ErrStopped = errors.New("stop requested") + func NewSource(s Sourcer, verbose bool, wakeup chan struct{}) (<-chan Task, chan<- Task, chan chan struct{}) + type GoPool struct + func New(name string, goroutines int, verbose bool, src <-chan Task) *GoPool + func (p *GoPool) Stop() + func (p *GoPool) String() string + type PriorityQueue struct + func NewPriorityQueue(name string) *PriorityQueue + func (q *PriorityQueue) Add(t Task) + func (q *PriorityQueue) Next() Task + func (q *PriorityQueue) String() string + type PriorityTask interface + Priority func() int + func NewPriorityTask(t Task, priority int) PriorityTask + type Sourcer interface + Add func(t Task) + Next func() Task + type Task interface + Run func(stop chan struct{}) error
Go to main page