关于Go语言中channel的问题。
来源:SegmentFault
时间:2023-01-17 16:57:16 462浏览 收藏
IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《关于Go语言中channel的问题。》,聊聊go,我们一起来看看吧!
问题内容
刚开始学习Go,看到gorountine和channel的时候试了试下面这个例子:
package main import ( "fmt" ) func display(msg string, c chan bool) { fmt.Println("display first message:", msg) c
这样的话会输出两行结果:
display first message: hello display first message: world
但是我总觉得应该只输出一行结果呢?main当中我定义了一个channel,之后分支出去两个gorountine去执行display函数,最后一行
阻塞等待数据。那么其中一个gorountine在打印完结果并向c发送数据后,main就接受到了数据,就应该继续执行然后结束了呀。怎么会打出两行结果呢?是不是我哪里理解的有问题?求指导,谢谢!正确答案
From goroutine scheduler
go runtime and go scheduler The runtime keeps track of each goroutine, and will schedule them to run in turn on a pool of threads belonging to the process. Goroutines are separate from threads but rely upon them to run, and scheduling goroutines onto threads effectively is crucial for the efficient performance of Go programs. The idea behind goroutines is that they are capable of running concurrently, like threads, but are also extremely lightweight in comparison. So, while there might be multiple threads created for a process running a Go program, the ratio of goroutines to threads should be much higher than 1-to-1. Multiple threads are often necessary to ensure that goroutines are not unnecessarily blocked. When one goroutine makes a blocking call, the thread running it must block. Therefore, at least one more thread should be created by the runtime to continue the execution of other goroutines that are not in blocking calls. Multiple threads are allowed to run in parallel up to a programmer defined maximum, which is stored in the variable GOMAXPROCS
Independently of cores and GOMAXPROCS, you can give the goroutine scheduler in the runtime a chance to do it's job. The scheduler cannot preempt a running goroutine but must wait for it to come back to the runtime and request some service, such as IO, time.Sleep(), or runtime.Gosched().
也就是说如果没有发生IO等需要挂起和谦让执行机会的时候,goroutine是不会终止的,除非执行完毕。
以我的理解来说明下这个问题。 主要问题是,这里虽然看似是开启了并发的模式,但实际上是单线程的,因为你没有设置GOMAXPROCS(默认是1,如果环境变量GOMAXPROCS也没有设置的话,该数值包含main thread),而且这些简单函数都不会导致阻塞操作,于是这样这些函数就是顺序执行的,没有并发效果。我们把你的例子修改一下改成下面这个
package main import ( "fmt" ) func display1(msg string, c chan bool) { fmt.Println("display first message:", msg) c上面这个运行的结果还是会产生两个语句,但是你会发现即使把display2的chan操作注释掉这里依然会输出两次,和chan的是否阻塞是没有关系的,而且没有发生需要挂起的操作。 我们修改成第二个示例
package main import ( "fmt" "time" ) func display1(msg string, c chan bool) { fmt.Println("display first message:", msg) c这个时候的输出就只有display1了,这是因为我们的goroutine发现display2可以挂起,于是交出CPU(此时两个goroutine是执行在同一个底层thread里面的),这时候程序继续执行顺利结束。 那如果我们的display2不愿意交出CPU呢?比如下面,我们在display2上绑定了一个CPU密集型的操作,这个时候我们的程序就会一直等,等到display2执行完才会结束,因为它无法交出CPU。
package main import ( "fmt" "time" ) func display1(msg string, c chan bool) { fmt.Println("display first message:", msg) c那我们不禁要问了那goroutine的优势在什么地方呢,如果它不能解决CPU的正常让出的话。首先要明确一个问题就是GO中影响groutine的重要参数GOMAXPROCS,系统默认是1,它决定的是底层可以用来运行goroutine的最大thread数目,这就是这里无法让出的原因,so,如果我们改成GOMAXPROCS大于1,上面的问题就解决了,因为我们的goroutine现在运行在两个不同的thread里面,如下,我们的程序不会等待display2就可以顺利结束。
package main import ( "fmt" "time" "runtime" ) func display1(msg string, c chan bool) { fmt.Println("display first message:", msg) c今天关于《关于Go语言中channel的问题。》的内容就介绍到这里了,是不是学起来一目了然!想要了解更多关于golang的内容请关注golang学习网公众号!
-
244 收藏
-
354 收藏
-
356 收藏
-
387 收藏
-
272 收藏
-
139 收藏
-
204 收藏
-
325 收藏
-
477 收藏
-
486 收藏
-
439 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 507次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习