channel 相关问题

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

具有手动信令的 WebRTC 数据通道的完整示例

我真的很难获得一个完整的 WebRTC 数据通道示例,我可以复制/粘贴它并且它可以工作。 我想要一个具有手动信号发送功能的 WebRTC 数据通道的 JavaScript 示例,我......

回答 2 投票 0

如何避免android FCM Flutter中出现杂项频道类别?

如何删除杂项频道? 它是由 fcm 创建的。我使用 flutter_local_notifications packege 创建频道并更改通知设置。但一些 Android 设备(三星 S10、...

回答 1 投票 0

为什么Java SIM卡安全通道返回“不匹配”?

我正在尝试在支持java卡V3.0.4的SIM卡上安装一个小程序。当我尝试建立安全通道来加载小程序时,卡返回错误: 模式_211 启用跟踪

回答 1 投票 0

当我将 daphne 添加到 Django 时,谁将服务 ASGI 和 WSGI?

当我在 INSTALLED_APPS 中添加 daphne 时,它将如何工作? 它本身可以为 WSGI 和 ASGI 提供服务吗? 或者它是否单独工作以仅服务于 ASGI? Gunicorn 仍在努力服务 WSGI 吗? 如果达芙妮 w...

回答 1 投票 0

对于性能关键型代码,我应该使用互斥体而不是通道吗?

我现在正在读《Go中的并发》这本书,这个决策树是为了教我们选择“原语”或“通道”而设计的。 这是性能关键的秒吗...

回答 1 投票 0

嗨,有人可以帮我解释一下 Golang 中的这个通道代码吗

导入“fmt” 函数主() { cnp := make(chan func(), 10) 对于我:= 0;我< 4; i++ { go func() { for f := range cnp { f() } ...

回答 1 投票 0

Go 的 Buffered Channel 的阻塞机制

在《Tour of Go》中,示例代码是这样给出的: 包主 导入“fmt” 函数主() { ch := make(chan int, 2) ch <- 1 ch <- 2 fmt.Println(<-ch) fmt.P...

回答 2 投票 0

为什么他们称 ASGI 为服务器,而他们说它不在 django 中?

我正在研究 Django Frameworke 中的通道。 之后我去研究 ASGI 规范,但我对以下内容感到困惑: 第一的 他们说ASGI是这里的服务器。 之后他们说 A...

回答 1 投票 0

如何通过 telethon 获取电报私人频道 id

嗨,我不知道如何解决这个问题,所以任何帮助将非常感激。 我订阅了私人频道。该频道没有用户名,我也没有邀请链接(管理员...

回答 4 投票 0

如何在nim中的线程之间设置一个小型的客户端-服务器示例?

对于 nim 中的 owlkettle 包(一种声明性 gtk 包装器),我正在研究如何“正确”实现多线程。 为此,我正在研究如何设置客户端......

回答 1 投票 0

工作池使用通道停止的恐慌

我正在编写一个工作线程池实现,在停止工作线程时遇到了问题。在运行 for _,worker := range p.workers {...} 循环后,我立即感到恐慌。我开始...

回答 1 投票 0

如何并行读取多个文件

我想并行读取多个文件,但遇到了死锁。 包主 进口 ( “布菲奥” “操作系统” “弦” ) 函数主() { var 目录名 = &qu...

回答 1 投票 0

指针通过通道丢失

这是Go代码 包主 进口 ( “FMMT” “数学/兰德” ) 类型 MyType 结构 { } 函数主() { chanAdd := make(chan *MyType, 1) chanRemove := make(chan *MyT...

回答 1 投票 0

如何确保通道读取不会超过选择中的任何其他情况

我有这两个功能: pointQueue = make(chan *mongo.UpdateOneModel, 1000) func UpdatePoints(用户名字符串,大小 int64) { 点差 := -1 * 大小 更新 := bson.D{{"$inc&q...

回答 1 投票 0

GoLang,确保通道读取不会超过选择中的任何其他情况

我目前有这两个功能 pointQueue = make(chan *mongo.UpdateOneModel, 1000) func UpdatePoints(用户名字符串,大小 int64) { 点差 := -1 * 大小 更新 := bson.D{{&...

回答 1 投票 0

API 调用是否有速率限制的并发?

我正在尝试对 telnyx(消息服务)API 进行并发 HTTP post 调用,然后使用响应更新数据库。 API 对我们的最大调用次数有 200/s 的限制。下面是我想出的代码...

回答 1 投票 0

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

我开发了以下内容: 包主 导入“fmt” 导入“时间” 函数添加(n int){ ch :=make(chan int) 总和:=0 对于我:= 0;i 我开发了以下内容: package main import "fmt" import "time" func add ( n int){ ch :=make(chan int) sum :=0 for i:= 0;i<n;i++{ sum = sum+i } ch <- sum fmt.Println("Sum is",sum) } func display(ch1 chan int){ fmt.Println("Sum is now",ch1) } func main() { ch2 :=make(chan int) go add(10) go display(ch2) fmt.Println("Hello World!") time.Sleep(time.Second) } 我想将当前总和传递到函数显示。 但是,当我打印总和时,我在控制台中收到以下消息: 世界你好! 现在总和是 0xc000094060 请帮忙打印当前金额。 您不是打印通道中的值,而是打印通道! 尝试: package main import "fmt" import "time" func add (ch chan int, n int){ sum :=0 for i:= 0;i<n;i++{ sum = sum+i } ch <- sum fmt.Println("Sum is",sum) } func display(ch chan int){ fmt.Println("Sum is now", <-ch) } func main() { ch :=make(chan int) go add(ch, 10) go display(ch) fmt.Println("Hello World!") time.Sleep(time.Second) } 另外,为什么要在 goroutine 中运行 display 呢? 如果你在 add 中做了一些复杂的事情并且花费的时间超过 1 秒,那么这个应用程序将停止并且不执行任何操作。也许看看等待组。

回答 1 投票 0

JSCH通道未开通(新)

问题:使用 JSCH 库通过 SFTP 连接远程站点会导致“通道未打开”。代码在一个互联网连接上工作正常,但在另一个互联网连接上则失败。另一种是通过代理完成的。

回答 2 投票 0

是否有用于 zOS 连接的 CICS (COBOL) 包装器,具有依赖子句?

是否有用于 z/OS 连接的 CICS (COBOL) 包装器程序示例? 我必须使用依赖条款。到目前为止,我对 z/OS 还很陌生。 我必须使用通道和容器。 考试...

回答 1 投票 0

如何在 Rust 中将消息从同步线程发送到异步任务

我有一个已经以同步风格编写的程序,它使用了一些需要它的必要库。但我认为它可能会受益于使用异步功能来实现其某些功能......

回答 1 投票 0

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