hold listener lock while waiting for goroutines to finish

staging/src/k8s.io/client-go/tools/cache/shared_informer.go

@@ -751,7 +751,6 @@ func (p *sharedProcessor) run(stopCh <-chan struct{}) {
 	}()
 	<-stopCh
 
-	func() {
 	p.listenersLock.Lock()
 	defer p.listenersLock.Unlock()
 	for listener := range p.listeners {
@@ -762,10 +761,8 @@ func (p *sharedProcessor) run(stopCh <-chan struct{}) {
 	// (processorListener cannot be re-used)
 	p.listeners = nil
 
-		// Reset to false since there are nil listeners, also to block new listeners
-		// that are added from being run now that the processor was stopped
+	// Reset to false since no listeners are running
 	p.listenersStarted = false
-	}()
 
 	p.wg.Wait() // Wait for all .pop() and .run() to stop
 }
@@ -789,7 +786,6 @@ func (p *sharedProcessor) shouldResync() bool {
 			listener.determineNextResync(now)
 		}
 	}
-
 	return resyncNeeded
 }