diff options
author | Gabriel Arakaki Giovanini <mail@gabrielgio.me> | 2023-06-24 00:34:57 +0200 |
---|---|---|
committer | Gabriel Arakaki Giovanini <mail@gabrielgio.me> | 2023-06-25 15:18:12 +0200 |
commit | 57b41ad766b3c4505672c12f058f10c7a132dd5b (patch) | |
tree | 80aea95babc8f740e86dadc7469236bdffc78c26 /pkg/worker/worker.go | |
parent | d5261d7f121985f13f9d19e9efd5c2ae3d4b5609 (diff) | |
download | lens-57b41ad766b3c4505672c12f058f10c7a132dd5b.tar.gz lens-57b41ad766b3c4505672c12f058f10c7a132dd5b.tar.bz2 lens-57b41ad766b3c4505672c12f058f10c7a132dd5b.zip |
feat: Remove unnecessary function
Diffstat (limited to 'pkg/worker/worker.go')
-rw-r--r-- | pkg/worker/worker.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go index 18cc0e2..359384a 100644 --- a/pkg/worker/worker.go +++ b/pkg/worker/worker.go @@ -20,7 +20,6 @@ type ( WorkerPool struct { workers []*Work - wg sync.WaitGroup } ) @@ -36,10 +35,13 @@ func (self *WorkerPool) AddWorker(name string, worker Worker) { } func (self *WorkerPool) Start(ctx context.Context) { - self.wg.Add(len(self.workers)) + var wg sync.WaitGroup + + wg.Add(len(self.workers)) + for _, w := range self.workers { go func(w *Work) { - defer self.wg.Done() + defer wg.Done() if err := w.Worker.Start(ctx); err != nil && !errors.Is(err, context.Canceled) { fmt.Println("Processes finished, error", w.Name, err.Error()) } else { @@ -47,8 +49,6 @@ func (self *WorkerPool) Start(ctx context.Context) { } }(w) } -} -func (self *WorkerPool) Wait() { - self.wg.Wait() + wg.Wait() } |