golang 实现并发求和
作者:butterfly5211314 发布时间:2024-02-02 07:15:58
标签:golang,并发,求和
使用golang并发求和,作为对golang并发的一个练习.
为了验证结果的正确性,要给出最传统的版本:
func sum1(data []int) int {
s := 0
l := len(data)
for i := 0; i < l; i++ {
s += data[i]
}
return s
}
第二种方法
使用N个goroutine, 然后将N个分段的和写入N个channel中:
func sum2(data []int) int {
s := 0
l := len(data)
const N = 5
seg := l / N
var chs [N]<-chan int
for i := 0; i < N; i++ {
chs[i] = worker(data[i*seg : (i+1)*seg])
}
for i := 0; i < N; i++ {
s += <-chs[i]
}
return s
}
func worker(s []int) <-chan int {
out := make(chan int)
go func() {
length := len(s)
sum := 0
for i := 0; i < length; i++ {
sum += s[i]
}
out <- sum
}()
return out
}
对于一个求和的任务来说,用worker这种“模式”可能 太过麻烦,
看第三种
直接一个函数写出来:
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 < N; i++ {
go func(ii int) {
tmpS := data[ii*seg : (ii+1)*seg]
ll := len(tmpS)
mu.Lock()
for i := 0; i < ll; i++ {
s += tmpS[i]
}
mu.Unlock()
wg.Done() // 一个goroutine运行完
}(i)
}
wg.Wait() // 等N个goroutine都运行完
return s
}
注意sum3要在读写s的地方加锁,因为s可能被多个goroutine并发读写。
最后一种方法有data race问题
不过运行结果是对的,看一下思路:
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 < N; i++ {
go subsum4(data[i*seg : (i+1)*seg])
}
// 这里是>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 < length; i++ {
sum += s[i]
}
sum4Tmp = sum4Tmp + sum
defer sum4mu.Unlock()
}
最后测试如下:
首先创建一个slice, 放1e8(1亿)个整数(范围[0,10))进去,
然后用4种方法进行计算
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 < MAX; i++ {
arr[i] = rand.Intn(10)
}
calcTime(sum1, arr, "for")
calcTime(sum2, arr, "worker")
calcTime(sum3, arr, "WaitGroup")
calcTime(sum4, arr, "NumGoroutine")
}
我的笔记本输出结果:
for: time: 61834200, sum: 450032946
worker: time: 51861100, sum: 450032946
WaitGroup: time: 153628200, sum: 450032946
NumGoroutine: time: 63791300, sum: 450032946
欢迎补充指正!
补充:Golang并发求和(竞争而非分段)
举例
如果要求2个goroutine并发完成1到100的和而不是分段的情况如何解决呢?
解决方案:
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 := <-ch:
if ok {
atomic.AddInt32(&sum, val)
} else {
break Loop
}
}
}
receiveCh <- sum
wg.Done()
}
func main() {
wg.Add(3)
ch = make(chan int32)
receiveCh = make(chan int32, 2)
go func(){
for i := 1; i <= 100; i++{
n := i //避免数据竞争
ch <- int32(n)
}
close(ch)
wg.Done()
}()
go add()
go add()
wg.Wait()
close(receiveCh)
var sum int32
sum = 0
for res := range receiveCh{
sum += res
}
fmt.Println("sum:",sum)
}
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。如有错误或未考虑完全的地方,望不吝赐教。
来源:https://gerrylon.blog.csdn.net/article/details/83341311
0
投稿
猜你喜欢
- 前言MySQL性能优化是一个老生常谈的问题,无论是在实际工作中还是面试中,都不可避免遇到相应的场景,下面博主就总结一些能够帮助大家解决这个问
- 编者按,网站中让人惊喜的往往是那一点细节,只要用心留意你将发现那些美好的用户体验就在身边。新蛋网想自主控制链接在原窗口还是新窗口中打开?看看
- 什么多态:同一事物有多种形态为何要有多态=》多态会带来什么样的特性,多态性多态性指的是可以在不考虑对象具体类型的情况下而直接使用对象多态指的
- 昨晚在往MySQL数据库中插入一组数据时,出错了!数据库无情了给我报了个错误:ERROR 1365(22012):Division by 0
- 为了访问数据库,就要提供数据库连接类,在C#中,是通过Connection类来实现的四种类型的连接方式SQLConnectionADOCon
- 引言你在写代码的过程中,有没有遇到过以下问题?已经写好的程序,想看看程序执行的进度?在写代码批量处理文件的时候,如何显示现在处理到第几个文件
- 本文实例讲述了Python文件的读写操作。分享给大家供大家参考,具体如下:读写文件读取文件f = open('my_path/my_
- 常见的SQL问题:◆选择重复,消除重复和选择出序列有例表:empemp_no name age001 Tom 17002 Sun 14003
- # -*- coding: utf-8 -*- import httplibfrom urllib import urlencodeimpo
- 我就废话不多说了,直接上代码吧!import cv2import timecap = cv2.VideoCapture(0)cap.set(
- Zabbix 是一款强大的开源网管监控工具,该工具的客户端与服务端是分开的,我们可以直接使用自带的zabbix_get命令来实现拉取客户端上
- 目录什么是websocket?第一步 准备工作第二步 编写聊天室页面第三步 编写后台websocket路由及处理方法第四步 运行看效果小结C
- 1、实例 DELIMITER // DROP PROCEDURE IF EXISTS `test`.`p_getvalue` // CREA
- 1、查看死锁1)用dba用户执行以下语句select username,lockwait,status,machine,program fr
- 虎扑体育-NBA球员得分数据排行 第1页 示例代码:import requestsfrom lxml import etreeur
- Python Json读写操作_JsonPath用法详解1. 介绍JSONPath是一种信息抽取类库,是从JSON文档中抽取指定信息的工具,
- 环境配置Django版本1.11python版本3.6.2前言在编写Django网站的时候,在涉及模板方面,一些简单的例子都没有问题,但这些
- 语法print('\033[显示方式;字体色;背景色m文本\033[0m')# 三种设置都可以忽略不写,都不写则为默认输出配
- 这次,我们用Turtle模块结合三角函数,绘制出这样的勾股树:首先,导入模块from turtle import *from math im
- 我还我还是有必要改一个标题,(原题为 让你想不通的"bug"),以免有同学误会。先看代码。看完之后我有个问题提问一下,看