channel 相关问题

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

rust tokio::sync::mpsc::channel is_empty() 当 len() 返回 0 时返回 false

我有一个 tokio::sync::mpsc::channel 打开,当 len() 方法返回 0 时,接收器的 is_empty() 方法返回 false。 这仅在 32 次循环后发生。诡异的。 任何人都知道为什么......

回答 1 投票 0

使用 tokio::sync::mpsc 将消息从同步发送到异步代码,发送者通道始终关闭

我得到了一段代码,其中大部分是在不同线程中运行的同步代码。 通信主要是通过 std::sync::mpsc::channel 完成的,但现在我需要传递一些其他代码

回答 1 投票 0

Wazuh 无法向 Slack WebHook URL 发送通知

我正在尝试在我的虚拟实验室设置中测试 Wazuh 安装。当我的目标机器上出现问题时,我需要来自 Wazuh 的通知(生成警报) 我试图收到这些

回答 1 投票 0

带有 WaitGroup 的 Goroutine 会执行相同的代码两次

我相对较新,并且在一些并发代码方面遇到了一些问题: 由于某种原因, else 块执行了两次,并且程序出现恐慌,并显示以下消息:恐慌:关闭已关闭的通道

回答 1 投票 0

Golang Go Routine 与 WaitGroup 执行相同的代码两次

我相对较新,并且在一些并发代码方面遇到了一些问题: 由于某种原因, else 块执行了两次,并且程序出现恐慌,并显示以下消息:恐慌:关闭已关闭的通道

回答 1 投票 0

上下文中的完成信号如何帮助取消请求?

这是来自 golang 上下文页面 https://blog.golang.org/context 的代码片段 func httpDo(ctx context.Context, req *http.Request, f func(*http.Response, error) error) error { // 运行 H...

回答 3 投票 0

有没有一种简单的方法可以使用带有类型消息的 BroadcastChannel 来代替任何方法?

const 频道 = new BroadcastChannel('foo'); 频道.postMessage(); 我知道有一个库(https://github.com/pubkey/broadcast-channel#create-a-typed-channel-in-types...

回答 2 投票 0

使用非阻塞模式的通知箱

我尝试遵循https://github.com/notify-rs/notify/blob/main/examples/async_monitor.rs,但是有一些阻塞线程,例如futures::executor::block_on。 所以我想无阻塞地使用它...

回答 1 投票 0

Go编程语言书中的聊天服务器示例中消息是如何输出到客户端的?

下面是 Alan Donovan 和 Brian Kernighan 的《Go 编程语言》一书第 8 章中的聊天服务器示例。 // Chat 是一个让客户端互相聊天的服务器。 包主 小鬼...

回答 1 投票 0

我应该在 conda 上安装哪个频道?

当我尝试下载高于 2.11 的版本的tensorflow时,我得到这个代码块,并想知道我应该获得哪个频道,以便我可以安装我需要的tensorflow版本 未找到软件包E...

回答 1 投票 0

导入错误:没有名为 asgi 的模块

为什么: 从channels.asgi导入get_channel_layer 结果是 : 从channels.asgi导入get_channel_layer 导入错误:没有名为 asgi 的模块 我正在使用 Django (1.9) 和 python(3.4)。而且,...

回答 5 投票 0

恐慌:测试:在 Go 中的 Init 案例之前调用 Verbose

尝试奔跑 https://github.com/adonovan/gopl.io/blob/master/ch8/cake/cake_test.go 但得到了 恐慌:测试:在 Init 之前调用 Verbose Goroutine 1 [运行]: 测试.详细(...) /usr/lib/go-1.1...

回答 2 投票 0

去缓冲通道同步

协程 x,y 通道a,5个缓冲区容量 事情是这样的:如果有一种情况,当 a 已满并且 x 试图将新项目放入 a 时,x 处会被阻塞。当你和我一起的时候...

回答 1 投票 0

如何在Golang中实现Goroutine的等待机制来检索池中的页面而不返回nil?

如何实现等待 goroutine 在已填充拉取的上下文中接收页面?因为如果没有错误,Page 永远不应该返回 nil。 类型浏览结构{ b *杆。

回答 1 投票 0

是 time.Tick 导致内存泄漏,因为你无法显式关闭通道,因为它是 Go 中的仅接收通道? return语句解决了吗

假设我有一个函数如下: 函数 fetchData() { 间隔 := 时间.分钟 * 15 股票代码 := time.Tick(间隔) 为了 { 选择 { 案例 <-ticker:

回答 1 投票 0

为什么这段 Go 代码不会造成死锁?

包主要 进口 ( “FMMT” “同步” “时间” ) var wgsync.WaitGroup 函数主() { ch := make(chan int) // 在 main() 中声明通道 wg.广告...

回答 1 投票 0

351 错误:找不到 distro-info==1.1+ubuntu0.1 的匹配发行版

我是码头工人的新手, 我正在使用一个 docker 项目,我正在尝试进行 docker compose 构建,但收到错误如下 351 错误:找不到 distro-info==1.1+ubuntu 的匹配发行版...

回答 1 投票 0

多个C#通道,相同类型,不同名称

在 C# 中使用通道时,我想运行具有相同基本类型的多个通道,但这会导致 DI 出现问题。例如 我想要一个高优先级通道和一个中优先级通道...

回答 2 投票 0

Golang 在超时 Goroutine 上的间歇性行为

我正在尝试实现重复任务的并发性。我想在不同的 Goroutine 上实现 http 请求(如 longRunningTask 函数所示)。我提供了一个计时器,用于...

回答 2 投票 0

Go 通道是如何实现的?

在(简要地)回顾了 Go 语言规范、有效的 Go 和 Go 内存模型之后,我仍然有点不清楚 Go 通道在幕后是如何工作的。 它们是什么样的结构?他们行动

回答 5 投票 0

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