Method Close

internal/engine/concurrent/task_queue.go:76–81

()

}

func (q *TaskQueue) Close() {
	q.mu.Lock()
	q.done = true
	q.cond.Broadcast()
	q.mu.Unlock()
}

func (q *TaskQueue) Len() int {
	return int(q.size.Load())