Struct GoQueue

pkg/aio/aio.go:101–107

GoQueue implements Queue using a pool of worker goroutines.

// GoQueue implements Queue using a pool of worker goroutines.
type GoQueue struct {
	requests    chan Request
	completions chan Completion
	shutdown    chan struct{}
	workers     sync.WaitGroup
	numWorkers  int
}

// NewGoQueue returns a new GoQueue with the given capacity.
func NewGoQueue(cap int) *GoQueue {