为什么我只能得到我启动的goroutine的部分错误,而不是所有的错误?

huangapple go评论86阅读模式
英文:

Why am I only getting part of error instead of all errors from goroutines I launch?

问题

我定义了一个Cycle类来处理并发任务。我想要的是同时运行两个函数,每个函数在一个goroutine中运行,等待它们完成并将它们的输出错误合并在一起。但是我只得到了一个错误。每个方法的职责如下:

Run - 在goroutine中运行一个函数,并收集其错误

WaitAllDone - 将所有函数的错误合并在一起,并等待所有函数完成

Do1, Do2 - 测试函数

最终的t.Log(err)输出的是ERR1ERR2,但我希望它输出ERR1 ERR2。为什么会丢失一个错误?

英文:

I define a Cycle class to handle concurrency task. What I want is run two functions, each in a goroutine, wait their finish and combine their output error together. But I only get one error. The responsibility of each method list below:

Run- run a function in goroutine, and collect its error

WaitAllDone- combine all function error together and wait all function finish

Do1, Do2 - test function

import (
	"fmt"
	"go.uber.org/multierr"
	"sync"
	"testing"
)

type Cycle struct {
	errChan chan error
	wg sync.WaitGroup
}

func NewCycle() *Cycle {
	return &Cycle{
		errChan: make(chan error),
		wg:      sync.WaitGroup{},
	}
}

// run fn and collect its error into error channel
func (c *Cycle) Run(fn func() error) {
	c.wg.Add(1)
	go func() {
		defer c.wg.Done()
		if err := fn(); err != nil {
			c.errChan <- err
		}
	}()
}

// wait all fn finish and combine their error together
func (c *Cycle) WaitAllDone() error {
	var err error
	go func() {
		for {
			if tmpErr, ok := <-c.errChan; ok {
				err = multierr.Append(err, tmpErr)
			} else{
				break
			}
		}
	}()
	c.wg.Wait()
	close(c.errChan)
	return err
}

func Do1() error {
	return fmt.Errorf("ERR1")
}

func Do2() error {
	return fmt.Errorf("ERR2")
}

func Test41(t *testing.T) {
	c := NewCycle()
	c.Run(Do1)
	c.Run(Do2)
	if err := c.WaitAllDone(); err != nil {
		t.Log(err)
	}
}

the final t.Log(err) output ERR1 or ERR2, but I want it output ERR1 ERR2. Why it miss one error.

答案1

得分: 1

这是因为(*Cycle).WaitAllDone不等待收集错误的goroutine完成。如果你使用-race标志运行代码,有时可能会报告多个数据竞争错误。以下是其中之一:

$ go test -race .
==================
WARNING: DATA RACE
Write at 0x00c0000a0610 by goroutine 10:
  m.(*Cycle).WaitAllDone.func1()
      /home/zeke/src/temp/76370962/main_test.go:40 +0xb6

Previous read at 0x00c0000a0610 by goroutine 7:
  m.(*Cycle).WaitAllDone()
      /home/zeke/src/temp/76370962/main_test.go:48 +0x14e
  m.Test41()
      /home/zeke/src/temp/76370962/main_test.go:63 +0xa4
  testing.tRunner()
      /snap/go/current/src/testing/testing.go:1576 +0x216
  testing.(*T).Run.func1()
      /snap/go/current/src/testing/testing.go:1629 +0x47

这个更改将修复这个问题:

  func (c *Cycle) WaitAllDone() error {
  	var err error
+ 	done := make(chan int)
  	go func() {
  		for {
  			if tmpErr, ok := <-c.errChan; ok {
  				err = multierr.Append(err, tmpErr)
  			} else {
  				break
  			}
  		}
+ 		close(done)
  	}()
  	c.wg.Wait()
  	close(c.errChan)
+ 	<-done
  	return err
  }

并且可以使用range子句简化for循环:

func (c *Cycle) WaitAllDone() error {
	var err error
	done := make(chan int)
	go func() {
		for tmpErr := range c.errChan {
			err = multierr.Append(err, tmpErr)
		}
		close(done)
	}()
	c.wg.Wait()
	close(c.errChan)
	<-done
	return err
}
英文:

That's because (*Cycle).WaitAllDone does not wait for the goroutine that collects the errors to finish. If you run the code with the -race flag, sometimes it could report several DATA RACE errors. Here is one of them:

$ go test -race .
==================
WARNING: DATA RACE
Write at 0x00c0000a0610 by goroutine 10:
  m.(*Cycle).WaitAllDone.func1()
      /home/zeke/src/temp/76370962/main_test.go:40 +0xb6

Previous read at 0x00c0000a0610 by goroutine 7:
  m.(*Cycle).WaitAllDone()
      /home/zeke/src/temp/76370962/main_test.go:48 +0x14e
  m.Test41()
      /home/zeke/src/temp/76370962/main_test.go:63 +0xa4
  testing.tRunner()
      /snap/go/current/src/testing/testing.go:1576 +0x216
  testing.(*T).Run.func1()
      /snap/go/current/src/testing/testing.go:1629 +0x47

This change will fix the issue:

  func (c *Cycle) WaitAllDone() error {
  	var err error
+ 	done := make(chan int)
  	go func() {
  		for {
  			if tmpErr, ok := <-c.errChan; ok {
  				err = multierr.Append(err, tmpErr)
  			} else {
  				break
  			}
  		}
+ 		close(done)
  	}()
  	c.wg.Wait()
  	close(c.errChan)
+ 	<-done
  	return err
  }

And the for loop can be simplified with the range clause:

func (c *Cycle) WaitAllDone() error {
	var err error
	done := make(chan int)
	go func() {
		for tmpErr := range c.errChan {
			err = multierr.Append(err, tmpErr)
		}
		close(done)
	}()
	c.wg.Wait()
	close(c.errChan)
	<-done
	return err
}

huangapple
  • 本文由 发表于 2023年5月31日 15:11:34
  • 转载请务必保留本文链接:https://go.coder-hub.com/76370962.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定