channel 相关问题

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

一个简单的Go模拟——并发问题

我是一名来自波兰的学生,这学期我开始了并发编程课程(Go、Ada,以及将来的一些理论和 CSP 语言)。不是说谎,Golang 看起来很有趣,但我有一点

回答 1 投票 0

缓冲通道大小限制

您好,我编写了这段代码来模拟异步发送电子邮件,但是如果我向该服务器发送 500 个并发请求,则前 100 个请求将能够将其电子邮件排队到

回答 1 投票 0

通道<Task> - 编写器在下一步逻辑之前等待任务结果

我有一个 Worker 类,用于处理作业消息。 我希望它串行处理消息,这样我就不需要在多线程调用者之间同步(锁定)其内部数据更改。 对于

回答 1 投票 0

Flex - 有没有办法更改“通道已断开”错误消息?

我有一个带有 PHP 后端的 Flash 应用程序。每当出现 PHP 错误时,我都会收到“在收到确认之前通道已断开”错误消息。 我正准备将我的项目推向......

回答 2 投票 0

使用通道将数据从一个 Goroutine 传递到另一个 Goroutine 的问题

我已经能够开发以下代码,该代码应该使用 go 通道将数据从一个例程传递到另一个例程: 包主 进口 ( “FMMT” “同步” ) func 生成数字(...

回答 1 投票 0

更快地关闭带有通道的 goroutine

我是 GO 新手,我有一个关于使用通道信号停止 goroutine 的问题。 我有一个长期运行的 goroutine(超过 1000 个)和管理器来管理它: func myThreadFunc(stop chan bool) { ...

回答 1 投票 0

为什么 main() Goroutine 在添加最后一个值后没有阻塞?

我有一个代码 包主 进口 ( “FMMT” ) func squares(c chan int) { 对于我:= 0;我< 4; i++ { num := <-c fmt.Println(num * num) } } func main() { ...

回答 1 投票 0

goroutines 完成通道无缓冲通道

在无缓冲通道中,默认情况下发送和接收块,直到发送者和接收者都准备好。 包主 进口 ( “FMMT” “时间” ) ...

回答 1 投票 0

随着程序中通道的引入,Go 程序陷入了解锁

我是 go 频道的新手, 我正在尝试通过构建模拟内核来学习 go 通道并通过通道处理通信。该示例程序的目的是拥有多个进程 (2)

回答 1 投票 0

Golang 中通道分配到底是如何工作的?

在下面的代码中,当我们在每次 go 例程调用后添加 b = a 时,从 ch 通道接收到的值为 4。 包主 导入“fmt” 函数主() { ch := make(chan int) 一个:...

回答 1 投票 0

HTTP2 .Net Framework 与 gRPC 的问题

我需要使用gRPC进行双向流,其中客户端是.Net Framework项目,由于遗留问题,无法升级到.NET5+。 当阅读微软文档时,我可以看到...

回答 2 投票 0

Go - 并发合并排序会挂起,除非在基本情况下有 fmt 调用

这是我对并发合并排序的尝试。我首先非并发地编写并测试了它,所以问题与合并排序逻辑无关,而是与我如何使用 goroutine/

回答 1 投票 0

通过通道和goroutine价值增加1000倍

我需要通过创建 1000 个 goroutine 将 x 增加 1000 倍,这将通过通道将 x 增加 1。我该怎么做? 包主 进口 ( “FMMT” ) 函数主() { 维...

回答 1 投票 0

在 tokio watch 频道中克隆接收者和订阅发送者有什么区别?

当使用 tokio watch 频道时,我注意到我可以使用发送方中的 subscribe 方法来获取另一个接收方,或者我可以克隆现有的接收方: let (发送者, mut 接收者) = watch::channel(1);...

回答 1 投票 0

Laravel /broadcasting/auth 总是被禁止并出现 403 错误

我尝试了很多解决方案,但没有一个适合我 我已经安装了 Laravel echo 和 Pusher js 以及 Pusher/Pusher #bootstrap.js 从 'laravel-echo' 导入 Echo; window.Pusher = require('pusher-js'); 赢...

回答 2 投票 0

无法使用django通道测试websocket

我正在尝试测试我的 websocket,但收到“404 未找到错误” 我不知道为什么我会收到错误。我检查了我的代码很多次但仍然没有用。 请看一看。 这是我的设置.py

回答 1 投票 0

React useContext 在 useeffect 中未定义

我正在使用 django 频道编写一个聊天应用程序并做出反应。我希望在发送新消息时获得当前用户的类名。 我已经在上下文中拥有当前用户,所以我只需调用...

回答 1 投票 0

使用 MPSC 通道在线程之间发送数据有时需要 5-10 秒,可能线程饥饿?

我尝试在两个线程之间发送一些数据,但另一个线程需要 5-10 秒才能接收到该数据。主线程正在运行一个 GUI(用 egui 编写),当...

回答 1 投票 0

Python 风格的生成器实现为通道:过早阅读

我尝试使用以下通道实现Python风格的生成器: 包主 进口 ( “FMMT” ) 类型 ContainerIterable[Tany] 结构 { 内容[]T } 函数 NewContainerIte...

回答 1 投票 0

使用 egui、tokio 和 std::sync::mpsc 无限循环和窗口冻结

通过通道传递消息时,我尝试迭代收到的响应,但不幸的是,我的窗口冻结了,当尝试打印调试时,表对象列表无限打印。 我的

回答 1 投票 0

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