ErrGroup-有错误返回的Goroutine控制

sync
留言 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package main

import (
	"fmt"
	"time"
)

func main() {

	timeNow := time.Now()

	a := f1()

	b := f2()

	c := f3()

	fmt.Println("和为:", a+b+c)

	fmt.Println("耗时:", time.Since(timeNow))

}

func f1() int {

	time.Sleep(1e9)

	return 1
}

func f2() int {

	time.Sleep(1e9)

	return 2
}

func f3() int {

	time.Sleep(1e9)

	return 3
}

运行结果为:

1
2
和为: 6
耗时: 3.00640904s

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
package main

import (
	"fmt"
	"golang.org/x/sync/errgroup"
	"time"
)

func main() {

	var (
		g = &errgroup.Group{}
		a int
		b int
		c int
	)

	timeNow := time.Now()

	g.Go(func() error {
		a = f1()
		return nil
	})

	g.Go(func() error {
		b = f2()
		return nil
	})

	g.Go(func() error {
		c = f3()
		return nil
	})

	g.Wait()

	fmt.Println("和为:", a+b+c)

	fmt.Println("耗时:", time.Since(timeNow))

}

func f1() int {

	time.Sleep(1e9)

	return 1
}

func f2() int {

	time.Sleep(1e9)

	return 2
}

func f3() int {

	time.Sleep(1e9)

	return 3
}

运行结果为:

1
2
和为: 6
耗时: 1.003517107s

文章目录