Do not generate unnecessary goroutine

cmd/kube-proxy/app/server.go

@@ -667,7 +667,7 @@ func (s *ProxyServer) Run() error {
 
 	// This has to start after the calls to NewServiceConfig and NewEndpointsConfig because those
 	// functions must configure their shared informer event handlers first.
-	go informerFactory.Start(wait.NeverStop)
+	informerFactory.Start(wait.NeverStop)
 
 	// Birth Cry after the birth is successful
 	s.birthCry()

pkg/controller/resourcequota/resource_quota_controller_test.go

@@ -127,7 +127,7 @@ func setupQuotaController(t *testing.T, kubeClient kubernetes.Interface, lister
 		t.Fatal(err)
 	}
 	stop := make(chan struct{})
-	go informerFactory.Start(stop)
+	informerFactory.Start(stop)
 	return quotaController{qc, stop}
 }
 

pkg/volume/csi/csi_attacher_test.go

@@ -1445,7 +1445,7 @@ func newTestWatchPlugin(t *testing.T, fakeClient *fakeclient.Clientset) (*csiPlu
 	factory := informers.NewSharedInformerFactory(fakeClient, csiResyncPeriod)
 	csiDriverInformer := factory.Storage().V1beta1().CSIDrivers()
 	csiDriverLister := csiDriverInformer.Lister()
-	go factory.Start(wait.NeverStop)
+	factory.Start(wait.NeverStop)
 
 	host := volumetest.NewFakeVolumeHostWithCSINodeName(
 		tmpDir,

pkg/volume/csi/csi_test.go

@@ -122,7 +122,7 @@ func TestCSI_VolumeAll(t *testing.T) {
 			fakeWatcher := watch.NewRaceFreeFake()
 
 			factory := informers.NewSharedInformerFactory(client, csiResyncPeriod)
-			go factory.Start(wait.NeverStop)
+			factory.Start(wait.NeverStop)
 
 			host := volumetest.NewFakeVolumeHostWithCSINodeName(
 				tmpDir,

pkg/volume/plugins.go

@@ -1034,7 +1034,7 @@ func (pm *VolumePluginMgr) Run(stopCh <-chan struct{}) {
 		// start informer for CSIDriver
 		if utilfeature.DefaultFeatureGate.Enabled(features.CSIDriverRegistry) {
 			informerFactory := kletHost.GetInformerFactory()
-			go informerFactory.Start(stopCh)
+			informerFactory.Start(stopCh)
 		}
 	}
 }