channel 相关问题

一种通信结构,支持在执行线程之间发送对象。您可以并且应该使用此标记来引用通用编程概念或各种语言或库中的特定实现。在后一种情况下,不要忘记添加适当的标签。

在select中的同一个通道上读写

可以通过这种方式使用一个通道在两个例程之间交换数据吗? c:= make(chan int)go func(){var i int select {case c

回答 1 投票 1

如何终止从服务器订购actioncable频道?

有没有办法从服务器端(控制器)终止对任何特定消费者的特定频道的订阅,以便可以调用我的咖啡脚本文件中的断开连接回调?...

回答 4 投票 6

Golang:关闭信道

我基于以下示例创建了一个简单的通道来发出异步HTTP请求:http://matt.aimonetti.net/posts/2012/11/27/real-life-concurrency-in-go/什么是最好 ...

回答 1 投票 1

如何创建仅限接收频道的频道?

我想创建一个频道,某人只能从中获取只接收频道,例如:c:= make(chan

回答 2 投票 0

注册多个SelectionKey

我正在使用NIO中的Java选择器。我正在使用特定频道和选择器注册我的选择键/兴趣键。现在,我的要求是有两个或更多的兴趣集...

回答 2 投票 0

golang中的无类型频道

我正在编写一些包,其中通道仅用于中断某个进程,因此它永远不会读取任何值,只是检测到它需要停止,如下所示:func myfunc(stop_chan chan / * bool * /){.. 。

回答 1 投票 -1

WebRTC数据通道带有手动信号,请举例?

我真的很难得到一个WebRTC数据通道示例的完整示例,我可以复制/粘贴它的工作原理。我想要一个带有手动信号的WebRTC数据通道的Javascript示例,即......

回答 1 投票 -1

为什么所有goroutines都睡着了?

以下是代码; package main import“fmt”func main(){func1(1)} func func1(n int){ch:= make(chan int)ch

回答 1 投票 0

通道:不同核心之间的通信

我想在两个不同的核心上运行两个函数之间的通道。以下代码不起作用:c1 = Channel(32)@spawnat 2 put!(c1,1)@spawnat 3 println(c1)println ...

回答 2 投票 0

同时收听一系列go频道[复制]

假设我有一段接收频道。有没有办法可以同时收听所有这些内容?例如:channels:= make([]

回答 1 投票 1

Python3,监听麦克风阵列的特定通道

我正在尝试使用Python 3.7收听麦克风阵列的第一个(0)通道(Respeaker v2.0)。这时,我可以收听6个频道:p = pyaudio.PyAudio()stream = p.open(rate = ...

回答 2 投票 0

是否可以从http Handle函数写入通道?

我想在发生http请求时将值传递给通道,我得到了这个代码:package main import(“io”“net / http”“time”)var channel1 chan int func main(){...

回答 2 投票 -2

等待gin HTTP服务器启动

我们正在使用杜松子酒在生产中公开一些REST API。现在,我必须在HTTP服务器启动后做一些事情。我对频道不是很熟悉,但是下面的代码就是我想要做的。 ...

回答 1 投票 0

惯用的goroutine终止和错误处理

我有一个简单的并发用例,它让我疯狂,我无法找到一个优雅的解决方案。任何帮助,将不胜感激。我想写一个方法fetchAll来查询...

回答 3 投票 5

如何在没有不稳定功能或外部板条箱的情况下从mpsc :: channel读取指定的时间?

我正在尝试连续读取接收器指定的持续时间。我想出了以下解决方案pub fn get (rx:&Receiver ,get_duration:time :: ...

回答 1 投票 1

是否可以打开频道?

如果我从不检查其状态,是否可以永久打开Go通道(从不关闭通道)?它会导致内存泄漏吗?以下代码可以吗? func(requestCh chan

回答 4 投票 121

具有通道参数的函数死锁

给出以下简单的Go程序:ch:= make(chan int)go fmt.Println(

回答 1 投票 3

用Go中的渠道实现承诺

我正在尝试在Go中实现Promise,这与Javascript中的类似。类型Promise struct {Result chan string Error chan error} func NewPromise()(* Promise){...

回答 4 投票 7

当Kotlin频道变满时执行一段代码

我想写一个简单的批处理器类。它有一个请求队列,等待这个队列变满或者要传递一段时间,然后再与数据库进行对话。这个很 ...

回答 2 投票 1

通过频道的范围进行例程

我在Golang工作了很长时间。但我仍然面临这个问题,虽然我知道我的问题的解决方案。但从未弄清楚为什么会这样。例如,如果我有一个管道......

回答 3 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.