草庐IT

匿名管道

全部标签

go - 并发如何与匿名函数一起工作?走

我正在尝试遍历列表(例如sql行)并为每一行触发例程。问题是传递给函数的值不会在运行时进行评估,因此根据函数执行所需的时间,它可能会使用下一行中的任何值而不是当前行。我知道我可以在普通函数中提取函数并传递参数,但我仍然想共享一些全局变量(以避免许多函数参数)因此需要使用匿名函数。仍然让我感到困惑的是,匿名函数在执行时从环境中获取变量,因为据我所知,它应该像&在unix程序中一样在单独的例程中执行,通信仅通过channel完成。问题是如何让匿名函数接收vc的副本并在运行时使用它?packagemainimport"fmt"import"time"typemystructstruct{ii

Go:匿名函数只取范围内的最后一个值

我认为这是一个非常简单的修复。只是尝试遍历字符串列表urls并在循环迭代时打印出每个url。但是当我添加并发(使用go和WaitGroup)时,它打印出的只是列表中的最后一个url。为什么它只打印出最后一个url(当从anon函数打印时)而不是在循环迭代时单独打印每个url?去Playground:http://play.golang.org/p/z4IZLY7Mt_代码:packagemainimport("fmt""sync")varurls=[]string{"http://google.com","http://facebook.com","http://youtube.com

使用 for 循环和匿名函数进行并发时出现意外行为

我已经找到了一种让代码按照我想要的方式运行的方法,但我想了解为什么它会这样运行,以便我对Go并发的理解有所提高。我正在测试sync.WaitGroup以等待一些goroutine完成,因为我计划以这种方式向AmazonS3进行多次上传。这是我最初的代码:funcmain(){varwgsync.WaitGroupfori:=1;i我惊讶地看到输出是:6,6,6,6,6。而不是像这样的:2,4,1,5,3。由于循环甚至没有转到6,这对我来说毫无意义。我后来将i变量作为参数传递给匿名函数然后它的行为符合我的预期。为什么会这样?我不明白。 最佳答案

mongodb - 如何使用 MGO 聚合管道查找符合特定条件的所有嵌入文档

假设我在MongoDB的Groups集合中有以下数据[{“Group”:{“_id”:1,“Requests”:[{“_id”:1,“name”:”RequestA”}.{“_id”:2,“name”:”RequestB”}]}},{“Group”:{“_id”:2,“Requests”:[{“_id”:3,“name”:”RequestC”}.{“_id”:4,“name”:”RequestD”}]}}]另外,假设我有以下功能funcGetRequests(requestIDs[]string)(Request[]error){//NEEDTOIMPLEMENTW/MGO}有没有办法

循环中的 Golang 匿名函数 - 作为参数传递的值的问题

我已经阅读了各种页面,例如https://github.com/golang/go/wiki/CommonMistakes其中概述了在循环中使用闭包和goroutines的问题。因此,我将原始循环编写如下:foroutstanding将不断变化的TTL作为参数传递给匿名函数。我最终得到了范围内的随机值。比如说,如果我期待1-5,我会得到几个1,几个3,也许是4。所以我尝试了以下方法,以防万一有关于专门使用循环实例化的变量的事情。是的,我知道我在这里有点滥用for循环...fori:=ttl;outstanding没有快乐。相同的经历。我还尝试了另一个建议的选项,您可以在循环中使用局部变

mongodb - 如何通过管道函数获取子字段值

我正在编写代码,用于在golang中从mongodb接收数据。我的代码如下:typeDataContentstruct{Createtime.Time`bson:"create"`Descstring`bson:"desc"`}typeDatastruct{Idbson.ObjectId`bson:"_id,omitempty"`Descstring`bson:"desc"`ContentDataContent`bson:"content"`}funcget()error{result:=[]Data{}coll:=session.DB(“”).C(“aaa”)project:=bso

go - big.NewInt 匿名变量的奇怪行为

在下面的代码片段中,我想做一个非常简单的计算d=a+b+c;a,b,c=b,c,d。它迭代了几次。在第一次尝试中,我创建了一个匿名变量big.NewInt(0).Add(a,b)来获取a+b的结果,然后将它和c相加得到a+b+c的最终结果。但是从第二次迭代开始,d.Add(big.NewInt(0).Add(a,b),c)改变了c的值,然后b,然后是a,当然最后的结果是错误的。然而,第二次尝试的方法给了我正确的答案。谁能告诉我为什么,好吗?packagemainimport("fmt""math/big")funcmain(){//firsttrya:=big.NewInt(1)b:=

linux -/dev/ttyACM0 Postfix 管道时文件不存在

当我以普通用户身份手动运行脚本时,一切正常。但是如果收到一封电子邮件并将其通过管道传输到Go脚本中,我将无法打开串口,因为文件不存在。postfix12391025013:20?00:00:00pipe-nwatchParadox-tunixflags=Fuser=watchargv=/usr/local/bin/watch-paradoxwatch12401239013:20?00:00:00/usr/local/bin/watch-paradox脚本在已添加到dialout组的watch用户下运行,为了确定,postfix用户也在dialout中。在我的脚本中,我运行了ls-la命

go - 如何通过运行时获取真实文件名。不同goroutine中匿名函数调用的调用者

我有这个示例代码https://play.golang.org/p/c_2GECIcrW我期望getFileName会打印出类似ma​​in.go:11的内容,但我得到的是asm_amd64p32.s:1014在这种情况下,我该怎么做才能得到预期的结果?我可以存档并继续使用匿名函数吗? 最佳答案 您的期望不正确。为了便于解释,让我在这里粘贴您的代码:packagemainimport("fmt""path/filepath""runtime""time")funcmain(){getFileName(1)time.Sleep(tim

go - 如何使用命名管道处理进程输出

我正在尝试从tmux中正在运行的进程设置管道,以便逐行处理其输出。我看过thisguidetopipetheoutputofatmuxsessiontostdout和thisarticleabout(named)pipesingo.我已经尝试了很长一段时间,但仍然没有得到任何值得注意的结果。如果有任何关于如何设置该管道的想法,我将不胜感激,理想情况下,我可以按行对其进行范围调整。非常感谢 最佳答案 这是我找到的解决方案here(谢谢Malcolm)funcReadln(r*bufio.Reader)(string,error){va