我是 Go 新手,在理解并发和 channel 方面存在问题。
package main
import "fmt"
func display(msg string, c chan bool){
fmt.Println("display first message:", msg)
c <- true
}
func sum(c chan bool){
sum := 0
for i:=0; i < 10000000000; i++ {
sum++
}
fmt.Println(sum)
c <- true
}
func main(){
c := make(chan bool)
go display("hello", c)
go sum(c)
<-c
}
程序的输出是:
display first message: hello
10000000000
但我认为应该只有一行:
display first message: hello
所以在 main 函数中,<-c 正在阻塞它并等待其他两个="" go="" rountine="" 向="" channel="" 发送数据。一旦="" main="" 函数从="" c="">-c>
display 和 sum 同时运行,sum 需要更长的时间,所以 display 应该向 c 发送 true 并且程序应该在 sum 完成之前退出......
我不确定我是否理解清楚。有人可以帮我解决这个问题吗?谢谢!
最佳答案
您的程序的确切输出没有定义,取决于调度程序。调度器可以在所有当前未被阻塞的 goroutine 之间自由选择。它试图通过在非常短的时间间隔内切换当前的 goroutine 来同时运行这些 goroutine,以便用户感觉到一切都是同时发生的。除此之外,它还可以在不同的 CPU 上并行执行多个 goroutine(如果你碰巧有一个多核系统并增加 runtime.GOMAXPROCS )。可能导致您输出的一种情况是:
main创建两个 goroutinesdisplay display打印出消息并被 channel 发送 (c <- true ) 阻止,因为还没有接收者。sum下一个sum goroutine(它已经使用了相当长的时间)并继续 display display将值发送到 channel 但这只是一种可能的执行顺序。还有很多其他的,其中一些会导致不同的输出。如果你只想打印第一个结果然后退出程序,你应该使用 result chan string并更改您的main打印功能fmt.Println(<-result) .
关于concurrency - Go并发和 channel 困惑,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18390852/
在我的路线文件中我有:match'graphs/(:id(/:action))'=>'graphs#(:action)'如果是GET请求(工作)或POST请求(不工作),我想匹配它我知道我可以使用以下方法在资源中声明POST请求:post'/'=>:show,:on=>:member但是我怎样才能为比赛做到这一点呢?谢谢。 最佳答案 如果你同时想要POST和GETmatch'graphs/(:id(/:action))'=>'graphs#(:action)',:via=>[:get,:post]编辑默认值可以设置如下match'g
在Railcasts上,我注意到一个非常有趣的功能“转到符号”窗口。它像Command-T一样工作,但显示当前文件中可用的类和方法。如何在vim中获取它? 最佳答案 尝试:helptags有各种程序和脚本可以生成标记文件。此外,标记文件格式非常简单,因此很容易将sed(1)或类似的脚本组合在一起,无论您使用何种语言,它们都可以生成标记文件。轻松获取标记文件(除了下载生成器之外)的关键在于格式化样式而不是实际解析语法。 关于ruby-on-rails-Textmate'Gotosymbol
我一直在学习Ruby,所以我想我应该尝试一下项目中的一些Euler难题。尴尬的是,我只完成了问题4...问题4如下:Apalindromicnumberreadsthesamebothways.Thelargestpalindromemadefromtheproductoftwo2-digitnumbersis9009=91×99.Findthelargestpalindromemadefromtheproductoftwo3-digitnumbers.所以我想我会在嵌套的for循环中从999循环到100并测试回文,然后在找到第一个(应该是最大的)时跳出循环:final=nilrang
为了防止在迁移到生产站点期间出现数据库事务错误,我们遵循了https://github.com/LendingHome/zero_downtime_migrations中列出的建议。(具体由https://robots.thoughtbot.com/how-to-create-postgres-indexes-concurrently-in概述),但在特别大的表上创建索引期间,即使是索引创建的“并发”方法也会锁定表并导致该表上的任何ActiveRecord创建或更新导致各自的事务失败有PG::InFailedSqlTransaction异常。下面是我们运行Rails4.2(使用Acti
我一直在研究ruby的并行/异步处理能力,并阅读了许多文章和博客文章。我查看了EventMachine、Fibers、Revactor、Reia等。不幸的是,我无法为这个非常简单的用例找到简单、有效(且非IO阻塞)的解决方案:File.open('somelogfile.txt')do|file|whileline=file.gets#(R)ReadfromIOline=process_line(line)#(P)Processthelinewrite_to_db(line)#(W)WritetheoutputtosomeIO(DBorfile)endend你看到了吗,我的小脚本正
我正在尝试查找名为Command的特定类型的所有子类在Ruby中,我遇到了以下代码,它完美地完成了这个技巧,但是我真的不明白它是如何工作的,主要是class部分。我已经尝试阅读此内容,但我觉得我仍然缺少一些Ruby魔法。有人可以向我解释一下吗:-)ObjectSpace.enum_for(:each_object,class 最佳答案 class返回Command的单例类.这是Command的唯一(直接)实例的类。在ruby中,C的子类的单例类是C的单例类的子类。所以Command的所有子类都有继承自Command的单例类的单例
我有生产服务器(Nginx+Passenger)。当我尝试从另一台计算机ab-n3-c3myhost.ru/时,我在我的nginxerror.log中收到此错误日志:[pid=21160thr=139775297914624file=ext/nginx/HelperAgent.cpp:584time=2011-08-3115:25:49.22]:UncaughtexceptioninPassengerServerclientthread:exception:Cannotreadresponsefrombackendprocess:Connectionresetbypeer(104)ba
假设一个使用类变量的简单ruby程序,classHolder@@var=99defHolder.var=(val)@@var=valenddefvar@@varendend@@var="toplevelvariable"a=Holder.newputsa.var我猜结果应该是99,但输出不是99。我想知道为什么。由于类变量的范围是类,我假设@@var="toplevelvariable"行不会影响类中的变量。 最佳答案 @@var是Holder的类变量。而顶层的@@var不是Holder的同名类变量@@var,是你在创建类Obj
我正在尝试了解CoffeeScript变量的范围。根据文档:ThisbehavioriseffectivelyidenticaltoRuby'sscopeforlocalvariables.但是,我发现它的工作方式不同。在CoffeeScript中a=1changeValue=->a=3changeValue()console.log"a:#{a}"#Thisdisplays3在ruby中a=1deffa=3endputsa#Thisdisplays1有人能解释一下吗? 最佳答案 Ruby的局部变量(以[a-z_]开头)arerea
“架设一个亿级高并发系统,是多数程序员、架构师的工作目标。许多的技术从业人员甚至有时会降薪去寻找这样的机会。但并不是所有人都有机会主导,甚至参与这样一个系统。今天我们用12306火车票购票这样一个业务场景来做DDD领域建模。”开篇要实现软件设计、软件开发在一个统一的思想、统一的节奏下进行,就应该有一个轻量级的框架对开发过程与代码编写做一定的约束。虽然DDD是一个软件开发的方法,而不是具体的技术或框架,但拥有一个轻量级的框架仍然是必要的,为了开发一个支持DDD的框架,首先需要理解DDD的基本概念和核心的组件。一.什么是领域驱动设计(DDD)首先要知道DDD是一种开发理念,核心是维护一个反应领域概