github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-07-18 09:11:10 +00:00
Code Issues Projects Releases Wiki Activity

unify worker num to workers

Browse Source 
Kubernetes-commit: e6df935fd30c56a8ece0da6152c60fc725d942b7
This commit is contained in:
astraw99 2021-08-09 10:48:53 +08:00 committed by Kubernetes Publisher
parent 3dc80a3333
commit a9a86ad864
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
examples/workqueue/main.go
View File

@ -116,7 +116,7 @@ func (c *Controller) handleErr(err error, key interface{}) {
} }
// Run begins watching and syncing. // Run begins watching and syncing.
func (c *Controller) Run(threadiness int, stopCh chan struct{}) { func (c *Controller) Run(workers int, stopCh chan struct{}) {
defer runtime.HandleCrash() defer runtime.HandleCrash()
// Let the workers stop when we are done // Let the workers stop when we are done
@ -131,7 +131,7 @@ func (c *Controller) Run(threadiness int, stopCh chan struct{}) {
return return
} }
for i := 0; i < threadiness; i++ { for i := 0; i < workers; i++ {
go wait.Until(c.runWorker, time.Second, stopCh) go wait.Until(c.runWorker, time.Second, stopCh)
} }