我想了解 Go 中的 channel 。我读过默认情况下发送和接收 block ,直到发送方和接收方都准备好。但是我们如何确定发送方和接收方的准备情况。
例如在下面的代码中
package main
import "fmt"
func main() {
ch := make(chan int)
ch <- 1
fmt.Println(<-ch)
}
程序将卡在 channel 发送操作上,永远等待有人读取值。即使我们在 println 语句中有一个接收操作,它也会以死锁结束。
但是对于下面的程序
package main
import "fmt"
func main() {
ch := make(chan int)
go func () {
ch <- 1
}()
fmt.Println(<-ch)
}
整数从go例程成功传递到主程序。是什么让这个计划奏效?为什么第二个有效但第一个无效? go routine 会造成一些差异吗?
最佳答案
让我们逐步完成第一个程序:
// My notes here
ch := make(chan int) // make a new int channel
ch <- 1 // block until we can send to that channel
// keep blocking
// keep blocking
// still waiting for a receiver
// no reason to stop blocking yet...
// this line is never reached, because it blocks above forever.
fmt.Println(<-ch)
第二个程序将发送拆分到它自己的执行行中,所以现在我们有:
ch := make(chan int) // make a new int channel
go func () { // start a new line of execution
ch <- 1 // block this second execution thread until we can send to that channel
}()
fmt.Println(<-ch) // block the main line of execution until we can read from that channel
由于这两条执行线可以独立工作,主线可以下到 fmt.Println 并尝试从 channel 接收。第二个线程将等待发送直到发送完毕。
关于去 channel 准备,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56261497/
假设我有一个id数组(从客户端接收):myArray=[1,5,19,27]我想返回该列表中(次要)id的所有项目。在SQL中这将是:SELECT*FROMItemsWHEREidIN(1,5,19,27)我知道我可以:Item.where(id:[1,5,9,27]),然而,将其添加到的查询使用准备语句语法的时间越长Item.where('myAttrib=?ANDmyOtherAttrib?ANDmyThirdAttrib=?',myVal[0],myVa[1],myVal[2])考虑到这一点,我想要的是:Item.where('idIN?',myArray)但是,这会产生语法错误
我正在使用Puppet进行机器配置。我有一个服务在Tomcat6应用程序服务器中运行,另一个list依赖于该服务(发送一些REST请求作为安装的一部分)。问题是,在开始使用tomcat后,该服务不可用:service{"tomcat6":ensure=>running,enable=>true,hasstatus=>true,hasrestart=>true;}所以我需要另一个list的一些要求条件,以确保服务真正运行(例如检查某些URL是否可用)。如果它还没有准备好,请等待一段时间,然后再试一次,并限制重试次数。是否有一些惯用的Puppet解决方案或其他解决方案可以实现这一目标?注意
我有以下代码执行oracleView,如下所示:defrun_queryconnection.exec_query("SELECT*FROMTABLE(FN_REQRESP(#{type_param},#{search_type_param},#{tid_param},#{last_param},#{key_param},#{tran_id_param},#{num_param},#{start_date_param},#{end_date_param}))")end上述查询的输出如下:SELECT*FROMTABLE(FN_REQRESP('ALL','ALL_TRAN','1000
我有一个订阅用户的ActionCable方法。如果开始新的session,我也想为用户订阅新channel。我想不出在Controller中调用channel方法的正确语法。更新:问题是消息在发送时附加到聊天框,但是当发送第一条消息时,websocket连接尚未建立,因此在用户看来好像消息没有发送(因为它没有被附加)。channel/msgs_channel.rbclassMsgsChannel在我的convosController中,create方法,我尝试了几种方法:convos_controller.rbdefcreate@convo=Convo.create!({sender_
如何检查准备好更新的gem,而不更新它们? 最佳答案 如果您没有使用bundler,只需运行gemoutdated,它会给您一个过时的gem列表。输出示例:$gemoutdatedacts_as_tree(2.7.1 关于ruby-on-rails-如何检查准备好更新的gem?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/11593091/
按照目前的情况,这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持,但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开,visitthehelpcenter指导。关闭11年前。我是一名经验丰富的网络开发人员,但只有一点点Ruby/Rails经验。我周一刚在一家Ruby商店接受面试,他们确实意识到我没有太多Ruby经验。除了我手边的2或3本Ruby书籍外,我还可以利用哪些其他资源来参加周末的Ruby速成类。顺便说一下,我在hostingrails上确实有一个最低限度的帐户,尽管我从未使用过它。我没有看到任何其他与搜索“rubyi
谷歌搜索了大约半天,我找不到任何使用pggem(postgresqlrubygem)准备好的INSERT语句的示例。我试过了(在查看了gem文档之后):deftest2conn=PG.connect(dbname:'db1')conn.prepare("statement1",'INSERTINTOtable1(id,name,profile)VALUES(?,?,?)')end但是我得到以下错误:pgtest.rb:19:in`prepare':ERROR:syntaxerroratornear","(PG::Error)LINE1:INSERTINTOtable1(id,nam
我正在尝试创建一个公开ActionCablechannel的gem,但我无法让它工作。这是我的宝贝#lib/my_channel.rbclassMyChannel然后我将gem添加到我的主要应用程序Gemfile,运行bundleinstall,启动控制台并运行MyChannel。没有屈服和错误,这意味着channel已正确包含。然后我将其添加到我的主应用程序//application.jsvarsocket="ws://localhost:3000/cable";varcable=ActionCable.createConsumer(socket);cable.subscriptio
RVM非常适合在本地机器上进行开发。但它在生产机器上安全吗? 最佳答案 我为生产构建了RVM,并在稍后添加了开发人员“细节”。如果您想了解更多信息,请阅读网站上的文档,并在美国东部时间大多数日子的白天某个时间在irc.freenode.net上的#rvm中与我交谈。 关于ruby-RVM生产准备好了吗?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/5864001/
Asitcurrentlystands,thisquestionisnotagoodfitforourQ&Aformat.Weexpectanswerstobesupportedbyfacts,references,orexpertise,butthisquestionwilllikelysolicitdebate,arguments,polling,orextendeddiscussion.Ifyoufeelthatthisquestioncanbeimprovedandpossiblyreopened,visitthehelpcenter提供指导。7年前关闭。有人在使用RoR进行大