golang 实现并发求和

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《golang 实现并发求和》，聊聊并发、求和，我们一起来看看吧！

使用golang并发求和，作为对golang并发的一个练习.

为了验证结果的正确性，要给出最传统的版本：

func sum1(data []int) int {
 s := 0
 l := len(data)
 for i := 0; i 

<h2>第二种方法</h2>
<p>使用N个goroutine， 然后将N个分段的和写入N个channel中：</p>

<pre class="brush:plain;">
func sum2(data []int) int {
 s := 0
 l := len(data)
 const N = 5
 seg := l / N
 var chs [N]

<p>对于一个求和的任务来说，用worker这种“模式”可能 太过麻烦，</p>
<h2>看第三种</h2>
<p>直接一个函数写出来：</p>

<pre class="brush:plain;">
func sum3(data []int) int {
 s := 0
 l := len(data)
 const N = 5
 seg := l / N
 var mu sync.Mutex
 var wg sync.WaitGroup
 wg.Add(N) // 直接加N个
 for i := 0; i 

<p>注意sum3要在读写s的地方加锁，因为s可能被多个goroutine并发读写。</p>
<h2>最后一种方法有data race问题</h2>
<p>不过运行结果是对的，看一下思路：</p>

<pre class="brush:plain;">
var sum4Tmp int
var sum4mu sync.Mutex
// 这个有data race问题，可以用WaitGroup改，只是提供一种思路
func sum4(data []int) int {
 //s := 0
 l := len(data)
 const N = 5
 seg := l / N
 for i := 0; i 1，因为要排除main
 // 这种方法不可靠，只是一种思路
 for runtime.NumGoroutine() > 1 {
 }
 // go run -race sum.go会报data race问题
 // main goroutine对它读
 // 别的goroutine会对它写（go subsum4)
 return sum4Tmp
}
func subsum4(s []int) {
 length := len(s)
 sum := 0
 sum4mu.Lock()
 for i := 0; i 

<p>最后测试如下：</p>
<p>首先创建一个slice, 放1e8(1亿)个整数(范围[0,10))进去,</p>
<h2>然后用4种方法进行计算</h2>

<pre class="brush:plain;">
func calcTime(f func([]int) int, arr []int, tag string) {
 t1 := time.Now().UnixNano()
 s := f(arr)
 t2 := time.Now().UnixNano() - t1
 fmt.Printf("%15s: time: %d, sum: %d\n", tag, t2, s)
}
func main() {
 const MAX = 1e8 // 1亿
 arr := make([]int, MAX)
 for i := 0; i 

<p>我的笔记本输出结果：</p>
<blockquote>
<p>for: time: 61834200, sum: 450032946</p>
<p>worker: time: 51861100, sum: 450032946</p>
<p>WaitGroup: time: 153628200, sum: 450032946</p>
<p>NumGoroutine: time: 63791300, sum: 450032946</p>
</blockquote>
<p>欢迎补充指正！</p>
<p><strong>补充：Golang并发求和（竞争而非分段）</strong></p>
<h2>举例</h2>
<p>如果要求2个goroutine并发完成1到100的和而不是分段的情况如何解决呢？</p>
<h2>解决方案：</h2>

<pre class="brush:plain;">
var wg sync.WaitGroup
var ch chan int32
var receiveCh chan int32
func add(){
	var sum int32
	sum = 0
	Loop:
	for {
		select {
		case val, ok := 

<p>以上为个人经验，希望能给大家一个参考，也希望大家多多支持golang学习网。如有错误或未考虑完全的地方，望不吝赐教。</p><p>终于介绍完啦！小伙伴们，这篇关于《golang 实现并发求和》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！</p>