channel 相关问题

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

Golang 通道写入和读取问题 - golang 通道新手

这是 golang 通道的简单生产者消费者问题。我想在频道中放入一些内容,然后将其写在控制台上。 包主 进口 ( “FMMT” “同步” ...

回答 1 投票 0

在 FreeSWITCH 中记录所有会议分支

我正在尝试录制电话会议,以便稍后可以查看他们的音频。要求是将每条腿记录在单独的文件中。进行一些谷歌搜索后,一种方法是通过

回答 2 投票 0

我可以不使用make函数来创建频道吗?

以下代码可以正常工作 函数主() { c := make(chan 字符串) go 子程序(c) fmt.Println(<-c) } func subRountine(c chan string) { c <- "hello" } Is there any

回答 2 投票 0


Golang 通道没有关闭

我对 go 尤其是频道还很陌生。我试图关闭一个通道,但它没有关闭,因此制定了方法 fmt.Println("transaksi 终于完成了") 和 fmt.Println("最终订单...

回答 1 投票 0

了解 Golang 并发:缓冲通道的意外行为

func taskScheduler(totalTasks int, taskQueue chan int, wg *sync.WaitGroup) { 推迟 wg.Done() 对于我:=0;我< totalTasks; i++ { fmt.Println("Scheduler is adding task to queue: ...

回答 1 投票 0

使用 range 来循环通道,为什么在接收到所有值之前就终止了?

此代码是《The Go 编程语言》一书中第 8.4 节程序的修改版本。 包主 进口 ( “FMMT” ) 函数主() { 自然 := make(chan int) 方形...

回答 0 投票 0

致命错误:所有 goroutine 都处于睡眠状态 - 死锁,使用通道

我收到死锁错误。我无法删除它。请让我知道我到底在哪里犯了错误 包主 进口 ( “FMMT” “同步” ) 函数 main() ...

回答 1 投票 0

如何在golang go例程中从一个通道读取输入并将输出写入另一个通道?

我正在学习golang,我想知道是否可以让一个goroutine从一个通道读取输入并将输出写入另一个通道,同时它受到waitgroup的限制? 请参阅下面的代码

回答 1 投票 0

比赛状态

当代码运行时,有时会打印attack()函数所花费的时间 我知道当攻击写入通道并且主要读取它然后主要退出并且不等待计时器时,它们是竞争条件(&...

回答 1 投票 0

优化golang聊天应用中的消息广播

我正在用 Golang 编写一个聊天应用程序。我下面有需要优化的示例代码。 类型集线器结构体{ 客户地图[int64]*客户 广播频道 *model.ChannelMes...

回答 1 投票 0

如何实现生产者为第三方的动态频道

我将连续数据接收到 NewMessage(Msg) 中,我需要将其卸载到线程池/工作线程,并且延迟非常重要。 NewMessage(Msg) 是从第三方库继承的方法...

回答 2 投票 0

通道未在第一个 API 请求时发送数据

我有一个 SSE 端点,它将数据发送到前端,并且该数据是从另一个 API 端点检索的。我对 go 中的通道还很陌生,似乎我必须触发 API 结束...

回答 1 投票 0

Asio中concurrent_channel的正确用法?

我目前正在学习如何使用boost asio中提供的concurrent_channel。不幸的是,boost asio 中没有并发通道的使用示例,所以我正在尝试编写一些演示...

回答 1 投票 0

msgpack.exceptions.ExtraData 在 AWS 上的 Django 通道中接收消息反序列化错误:

我正在使用 Django 和 Django Channels 开发一个 Web 应用程序,在处理 WebSocket 消费者接收事件时遇到了问题。当接收到来自客户端的消息时,

回答 1 投票 0

如何使用 Apache 和 Daphne 部署 django 通道?

我正在尝试部署这个使用通道的 django 应用程序。我使用 Apache 进行常规 HTTP 请求,并希望将 Web 套接字请求转发到 Daphne。 以下是我的一些重要文件: 阿帕奇...

回答 2 投票 0

写入通道的随机结果(Go)

我有以下代码: 函数 writeToClosedBufferedChannel() { ch := make(chan int, 2) ch <- 10 ch <- 20 go func() { fmt.Println("test") ch <- ...

回答 1 投票 0

这是什么意思 Redis URL 必须指定以下方案之一(redis://、rediss://、unix://)

文件上传完成并且要进行重定向后,我收到此错误消息。 Redis URL 必须指定以下方案之一(redis://、rediss://、unix://) 我不是...

回答 1 投票 0

Goroutines with time.Sleep 工作,但 WaitGroup 导致错误 - 同步问题?

我正在尝试同步2个goroutines,例如gr1和gr2交替运行。 为此,我使用 2 个通道进行协调。 当我使用 time.Sleep 等待 goroutine 完成时,它正在工作

回答 1 投票 0

如果没有 ssh_channel_read,ssh_channel_request_exec 将无法工作

我正在使用 ssh_channel_request_exec 在远程节点上执行命令“mkdir -p ~/.temp”。当 ssh_channel_request_exec 与 ssh_channel_read 一起使用时,目录的创建是

回答 1 投票 0

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