fix

Signed-off-by: dongjiang <[email protected]>

Author: dongjiang1989

pkg/controller/priorityqueue/priorityqueue.go

@@ -317,7 +317,6 @@ func (w *priorityqueue[T]) Done(item T) {
 func (w *priorityqueue[T]) ShutDown() {
 	w.shutdown.Store(true)
 	close(w.done)
-	close(w.get)
 }
 
 // ShutDownWithDrain just calls ShutDown, as the draining

pkg/controller/priorityqueue/priorityqueue_test.go

@@ -307,6 +307,7 @@ var _ = Describe("Controllerworkqueue", func() {
 		q.Add("baz")
 		// shut down
 		q.ShutDown()
+		q.AddWithOpts(AddOpts{After: time.Second}, "foo")
 
 		item, priority, isShutDown := q.GetWithPriority()
 		Expect(item).To(Equal(""))