Golang超全面讲解并发
来源:脚本之家
时间:2022-12-28 19:47:26 255浏览 收藏
亲爱的编程学习爱好者,如果你点开了这篇文章,说明你对《Golang超全面讲解并发》很感兴趣。本篇文章就来给大家详细解析一下,主要介绍一下并发,希望所有认真读完的童鞋们,都有实质性的提高。
1. goroutine
1.1 定义
func main() { for i := 0; igo语言是采用一种叫 协程(Coroutine)
轻量级 “线程”
非抢占式 多任务处理,由协程主动交出CPU控制权
- 线程是由CPU来决定是否移交控制权,做到一半可能线程就会进行切换
- 协程则是由内部进行决定是否要移交CPU的控制权
编译器/解释器/虚拟机层面的多任务
多个协程可以在一个或者多个线程上运行 (由调度器来决定)
以下例子,通过 runtime.Gosched() 可以手动交出控制权,如果不交出控制权;还有如果在 gorotine 里面使用外部函数,如果不传入的话,就是一个闭包的变量,会导致数据冲突,就是通过不同的协程写入数据。检查数据是否有冲突可以通过以下语句进行检测
go run -race
func main() { var a [10]int for i := 0; i普通函数:在一个线程里面执行,调用完后释放资源,单向调用
协程:双向流通
但go的程序启动时,一个线程里面可能有多个 goroutine 执行,具体在哪个线程执行,由调度器决定;传统意义上的 routine 需要显示的写出释放控制权,而 goroutine 不需要写出来,调度器会进行切换
1.2 goroutine切换点
只是参考,不能保证肯定会切换
- I/O, select:打印数据的时候
- channel
- 等待锁
- 函数调用(有时)
- runtime.Gosched()
2. channel
协程与协程之间的双向通信
2.1 语法
func chanDemo() { //var c chan int //为 nil 的chan不能使用 c := make(chan int) go func() { for { n :=2.2 channel作为参数
func worker(i int, c chan int) { for { fmt.Printf("Worker :%d, accpet: %c \n", i,2.3 channel作为返回值
返回值定义:chan
// chan创建时可以指定 channel 的大小,make(chan int, 3) 如果数据超过3个就会死锁,对提升性能有好处。
2.4 chan关闭
如果不 close 那么会一直接收下去,可以是否 if、range 进行判断是否 close
不要通过共享内存来进行通信,要通过通信来共享内存
func chanClose() { //创建一个缓冲区 c := make(chan int, 3) c2.5 等待goroutine
如何等待所有的 goroutine 执行完之后才退出程序?
方式一:
func ChanDemo() { workers := make([]worker, 10) for i, _ := range workers { workers[i] = createWorker(i) } for i, worker := range workers{ worker.in方式二:
使用 sync.WaitGroup 等待所有的 gorounte 执行结束
//定义一个worker的结构用来存放 chan数据 type done2Worker struct { in chan int //使用指针传递 wg *sync.WaitGroup } func create2Worker(id int, group *sync.WaitGroup) done2Worker { w := done2Worker{ wg: group, in: make(chan int), } go do2Worker(id, w) return w } func do2Worker(id int, worker2 done2Worker) { for i := range worker2.in { fmt.Printf("Worker:%d, accept:%c \n", id, i) //执行完成 worker2.wg.Done() } } func Chan2Demo() { var wg sync.WaitGroup workers := make([]done2Worker, 10) for i, _ := range workers { workers[i] = create2Worker(i, &wg) } wg.Add(20) for i, worker := range workers { worker.in3. select
select 可以对 channel 进行非阻塞式调用,谁先来执行谁,在 select 中也可以使用 nil 进行调度
func generator() chan int { out := make(chan int) go func() { i := 0 for { //休眠随机数 time.Sleep(time.Duration(rand.Intn(1500)) * time.Millisecond) out4. 传统同步机制
CSP : 模型下面尽量少用传统的同步方式,传统的方式使用共享变量进行使用
- WaitGroup
- Mutex
type atomicInt struct { a int //定义互斥量进行同步 lock sync.Mutex } func (a *atomicInt) add() { a.lock.Lock() defer a.lock.Unlock() a.a++ } func main() { a := atomicInt{ a: 0, } a.add() go a.add() time.Sleep(time.Millisecond) fmt.Println("value : ", a.a) }
Cond
5. 并发模式
5.1 生成器
//传入多个chan,返回一个只能输出的chan func fanIn(chs...chan string)5.2 定义接口
// ChannelCreateFunc 创建接口,需要传入管道,以及参数 type ChannelCreateFunc interface { // Create 创建函数传入一个任何类型的管道,后面参数选择性传入 Create(ch5.3 非阻塞管道
新建 noblock.go,定义下面这样的格式
type NotBlockCreator struct { } func (n NotBlockCreator) Create(ch5.4 超时管道
新建 timeout.go
type TimeoutCreator struct { } func (t TimeoutCreator) Create(ch6. 广度优先算法(迷宫)
每次探索都是一层一层的向外进行探索,如果起始为0,那么先将周边的 1 进行探索完毕,探索1时会将1的点位先存入到队列中,等后续所有的1都探索完成之后,再取出1的点位进行1周边的探索
通过上面的这种点位算法,就可以将迷宫的路画出来
6.1 代码实现
创建文本,这里需要注意,idea创建文件分隔符编码需要设置以下,否则后续读取文件时会有问题
6 5
0 1 0 0 0
0 0 0 1 0
0 1 0 1 0
1 1 1 0 0
0 1 0 0 1
0 1 0 0 0读取文件成二维数组
// Fscanf函数在读取文件时,遇到\r为默认替换为0,读取\n结束,如果编码不对,这里读取就会出问题 func readMaze(path string) [][]int { file, err := os.Open(path) if err != nil { panic(err) } var row, col int //这里需要取地址,函数里面会更改row和col的值 fmt.Fscanf(file, "%d %d", &row, &col) fmt.Printf("%d\t%d\n", row, col) //创建一个二位数组,一共有多少行 maze := make([][]int, row) for i := range maze { //创建列 maze[i] = make([]int, col) for j := range maze[i] { fmt.Fscanf(file, "%d", &maze[i][j]) } } return maze } func main() { //读取迷宫文件 maze := readMaze("maze/maze.in") for _, row := range maze { for _, col := range row { fmt.Printf("%d\t", col) } fmt.Println() } }//点位的结构体 type point struct { i, j int } //定义需要探索的方向 var dirs = [4]point { //当前位置-1,就是向上 {-1, 0}, //左边的点位 {0, -1}, //向下的点位 {1, 0}, //向右的点位 {0, 1}, } //将两个点位相加,就可以获取到下一个点位 func (p point) add(r point) point { return point{p.i + r.i, p.j + r.j} } func (p point) at(grid [][]int) (int, bool) { //首先判断点位是否越界了,例如传入的点位 (-1,0)或者(1, -1) if p.i = len(grid) { return 0, false } //判断j列是否越界了 if p.j = len(grid[p.i]) { return 0, false } //返回数据 return grid[p.i][p.j], true } // walk 传入迷宫,指定迷宫开始的点位,以及出口的点位 func walk(maze [][]int, start, end point) [][]int { //创建走过的步 steps := make([][]int, len(maze)) for i := range steps { steps[i] = make([]int, len(maze[i])) } //创建需要探索的队列,初始的点位(0,0) Q := []point{start} for len(Q) > 0 { cur := Q[0] //截取出队列中的头部 Q = Q[1:] //判断如果点位等于出口的点位,那么直接退出 if cur == end { break } //dirs为点位周边的四个方向,我这里采用的是 上、左、下、右 的方向进行探索 for _, dir := range dirs { //将当前点位跟四个方向相加,例如 (0,0) 向上的方向就是(-1,0),将i的值进行减1 next := cur.add(dir) //判断向上的点位不能超出迷宫的界限,并且返回在迷宫中的值,因为如果返回的值为1,就证明是墙 val, ok := next.at(maze) if !ok || val == 1 { continue } //不等0就证明是墙 val, ok = next.at(steps) if !ok || val != 0 { continue } //如果是起点,就跳过 if next == start { continue } //获取到当前步数的值 curSteps, _ := cur.at(steps) //将走过的点位追加到切片中 steps[next.i][next.j] = curSteps + 1 //继续将下一个点位添加到需要探索的队列当中 Q = append(Q, next) } } return steps }以上就是《Golang超全面讲解并发》的详细内容,更多关于golang的资料请关注golang学习网公众号!
-
417 收藏
-
328 收藏
-
367 收藏
-
221 收藏
-
109 收藏
-
444 收藏
-
311 收藏
-
266 收藏
-
188 收藏
-
317 收藏
-
430 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 507次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习
-
- 闪闪的狗
- 这篇博文出现的刚刚好,太详细了,真优秀,码住,关注作者大大了!希望作者大大能多写Golang相关的文章。
- 2023-01-20 06:48:55
-
- 疯狂的百褶裙
- 很有用,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,看完之后很有帮助,总算是懂了,感谢博主分享文章!
- 2023-01-15 11:08:07
-
- 柔弱的鸡
- 这篇文章内容出现的刚刚好,太详细了,很棒,mark,关注up主了!希望up主能多写Golang相关的文章。
- 2023-01-09 16:25:28
-
- 愉快的奇迹
- 这篇技术贴出现的刚刚好,楼主加油!
- 2023-01-06 14:56:27
-
- 文艺的西装
- 这篇技术文章真是及时雨啊,太细致了,真优秀,已收藏,关注作者大大了!希望作者大大能多写Golang相关的文章。
- 2023-01-03 21:21:05
-
- 失眠的芒果
- 太详细了,mark,感谢老哥的这篇文章内容,我会继续支持!
- 2023-01-03 04:59:16
-
- 含糊的航空
- 赞 👍👍,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,看完之后很有帮助,总算是懂了,感谢博主分享文章内容!
- 2022-12-30 14:13:19
-
- 淡然的萝莉
- 这篇文章内容太及时了,太详细了,感谢大佬分享,码住,关注作者了!希望作者能多写Golang相关的文章。
- 2022-12-30 03:33:49