草庐IT

缓冲池

全部标签

go - 捕获 exec.Command 的缓冲标准输出输出

我正在尝试捕捉外部程序的输出。示例:#include#include#includeintmain(){inti=0;while(i这是我的main.go:packagemainimport("bufio""io""log""os/exec")funcreecho(closerio.ReadCloser){reader:=bufio.NewReader(closer)for{s,e:=reader.ReadString('\n')ife!=nil{log.Println(e)break}log.Println(s)}}funcmain(){cmd:=exec.Command("./in

go - 在 Go 中清除缓冲区

我是Golang的新手,当我尝试获取连续输入时,第一个scanf()获取输入而剩余的scanf()被省略例如:fmt.Println("EnterA:")fmt.Scanf("%d",a)fmt.Println("EnterB:")fmt.Scanf("%d",b)在这里,第一个Scanf起作用,而第二个没有得到任何输入 最佳答案 使用scan而不是scanf,因为您正在尝试获取int,vara,bintfmt.Println("EnterA:")fmt.Scan(&a)fmt.Println("EnterB:")fmt.Scan(

go - 如何等到缓冲 channel (信号量)为空?

我有一片整数,它们是并发操作的:ints:=[]int{1,2,3,4,5,6,7,8,9,10}我使用缓冲channel作为信号量,以便获得并发运行的go例程的上限:sem:=make(chanstruct{},2)for_,i:=rangeints{//acquiresemaphoresem上面的代码在达到最后一个或最后两个整数之前运行良好,因为程序在最后一个go例程完成之前结束。问题:如何等待缓冲channel耗尽? 最佳答案 您不能以这种方式使用信号量(在本例中为channel)。当您处理值和分派(dispatch)更多go

go - 从 exec 命令 stdout 读取而不缓冲

我正在通过exec.Command在Go中运行命令并扫描输出。在某些系统上,输出是立即的。但在某些系统上,输出似乎被缓冲了。除非命令产生的数据量足够大,否则我实际上不会收到输出。有没有办法可靠地获得更即时的输出?packagemainimport("fmt""log""os/exec""time")funcmain(){cmd:=exec.Command("udevadm","monitor")stdout,err:=cmd.StdoutPipe()iferr!=nil{log.Fatal(err)}err=cmd.Start()iferr!=nil{log.Fatal(err)}fo

golang 异步缓冲 channel 挂起

作为第一个项目,我决定编写一个简单的异步web-scaper。我的想法是有一个任务队列和一个“解决”任务的worker池。在编写程序时遇到了一个问题。以下代码挂起:packagemainimport("fmt""net/http""time")typeScraperstruct{clienthttp.Clienttimeoutinttaskschanstringresultschanintntasksint}func(sScraper)Init(timeoutint,workersint){s.client=http.Client{Timeout:time.Second*time.Du

concurrency - 缓冲 channel 关闭 TRUE?

我有一些问题......关于缓冲channelQ1.那为什么NonBuffered永远不会输出TRUE值?这是否意味着无缓冲channel总是关闭的?那为什么无缓冲channel仍然产生正确的斐波那契计算结果?Q2.为什么NonBuffered输出像下面这样在中间被切断?0112NBvalue:0NBok:false3应该是goroutine相关的东西,为什么会这样?这很难理解,因为如果我缓冲这个channel,我会得到真正的值(value),但对于无缓冲的channel,我只会得到错误的...请查看以下链接。http://play.golang.org/p/O2Th61DfEYpac

concurrency - 如何在没有死锁的情况下在缓冲 channel 上循环?

我想知道如何排出/关闭缓冲channel,以免陷入僵局?我正在使用range循环遍历channel,但似乎尽管它们被“读取”,但它们并没有像非缓冲channel那样关闭。packagemainfuncmain(){cp:=2ch:=make(chanstring,cp)fori:=0;iPlay 最佳答案 您可以使用close()builtin关闭channel.这必须在您的所有并发处理完成后调用。你如何做取决于你想做什么。在您当前的架构中,您似乎必须建立一个全局状态,它可以跟踪您的所有流程并确定最后一个流程是否已完成。这种状态可以

emacs - 如何关闭 go 缓冲区中的 ‘tab’ 突出显示?

我刚开始在Emacs中编写Go程序。如何关闭go-mode缓冲区中的选项卡突出显示?我使用«whitespace»来突出显示空白字符。顺便说一下,Go是唯一我不想突出显示选项卡的模式,因为选项卡是Go中的标准格式。此致,帕维尔。 最佳答案 要清楚,你正在做类似的事情(require'whitespace)(global-whitespace-modet)对吧?您可以使用为go-mode禁用whitespace-mode(setqwhitespace-global-modes'(notgo-mode))有一个relatedquesti

go - 填充缓冲 channel 直到变满或持续时间过去

我有一个缓冲的chanstring,我一直用随机字符串填充它直到time.Duration过去或直到它变满。我的问题是考虑到它是一次性任务,我应该使用自动收报机还是有更方便的方法?这是我目前的做法packagemainimport("fmt""time")funcmain(){res:=fillChan(time.Duration(1*time.Nanosecond),100000)fmt.Println(len(res))}funcfillChan(maxDurationtime.Duration,chanSizeint)chanstring{c:=make(chanstring,c

sockets - 没有可用的缓冲区空间(tcp.cpp :69) when setting SNDBUF and RCVBUF ZeroMQ, golang,MacOSX

我在MacOSX上使用brew安装了zeromq:stable4.1.4,并编写了一个简单的PUB/SUB程序来测试zeromq。但是当我使用标志--bufsize>5运行示例程序时(使用大小>5MB的缓冲区)(去运行go_zmq_pubsub.go--bufsize=6);它抛出以下异常:没有可用的缓冲区空间(tcp.cpp:69)SIGABRT:中止PC=0x7fff9911c286m=0cgo执行时信号到达下面是我用来测试zeromq4.x的程序packagemainimport("fmt""flag""strconv""sync"log"github.com/Sirupsen/