Make sure the workers are awaked when BufferedChannelQueue.GetChannel().

johnteee · johnteee · commit 2e9a1080de2b · 2022-05-17T12:37:54.000+08:00
diff --git a/queue.go b/queue.go
@@ -645,6 +645,8 @@ func (q *BufferedChannelQueue[T]) GetFreeNodeHookPoolIntervalDuration() time.Dur
 
 // GetChannel Get Channel(for Selecting channels usages)
 func (q *BufferedChannelQueue[T]) GetChannel() chan T {
+	q.notifyWorkers()
+
 	return q.blockingQueue
 }
 

Original file line number	Diff line number	Diff line change
`@@ -645,6 +645,8 @@ func (q *BufferedChannelQueue[T]) GetFreeNodeHookPoolIntervalDuration() time.Dur`
`645`	`645`
`646`	`646`	`// GetChannel Get Channel(for Selecting channels usages)`
`647`	`647`	`func (q *BufferedChannelQueue[T]) GetChannel() chan T {`
	`648`	`+ q.notifyWorkers()`
	`649`	`+`
`648`	`650`	`return q.blockingQueue`
`649`	`651`	`}`
`650`	`652`