Skip to content

Commit 93e048e

Browse files
committed
remove cyclic dependancy
1 parent 3a5c401 commit 93e048e

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

pkg/workerpool/pool.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package Taskerpool
22

33
import (
44
"fmt"
5-
"github.com/sdslabs/beastv4/core/manager"
65
"runtime"
76
"sync"
87

@@ -54,15 +53,15 @@ func (q *Queue) Pop(ID string) {
5453
}
5554

5655
func (q *Queue) Stop() {
57-
ids := make([]string, len(manager.Q.InQueue))
56+
ids := make([]string, len(q.InQueue))
5857
i := 0
59-
for id, _ := range manager.Q.InQueue {
58+
for id, _ := range q.InQueue {
6059
ids[i] = id
6160
i++
6261
}
6362

6463
for _, id := range ids {
65-
manager.Q.Pop(id)
64+
q.Pop(id)
6665
}
6766
}
6867

0 commit comments

Comments
 (0)