We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 42307d0 commit 1e8fc85Copy full SHA for 1e8fc85
internal/worker/workqueue.go
@@ -3,9 +3,8 @@ package worker
3
import "context"
4
5
type workQueue[Task any] struct {
6
- tasks chan *Task
7
- slots chan struct{}
8
- emptyNotify chan struct{}
+ tasks chan *Task
+ slots chan struct{}
9
}
10
11
func newWorkQueue[Task any](maxParallelTasks int) *workQueue[Task] {
0 commit comments