writequeue

type Queue ¶

type Queue struct {
	// contains filtered or unexported fields
}

Queue runs submitted tasks in submission order without blocking the caller. A task may block on the underlying stream; only the queue worker waits for it.

func (q *Queue) Submit(task func())