channel 相关问题

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

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

go concurrency channel goroutine

回答 1 投票 0

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

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

go concurrency semaphore channel rate

回答 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 秒，那么这个应用程序将停止并且不执行任何操作。也许看看等待组。

multithreading go concurrency channel goroutine

回答 1 投票 0

JSCH通道未开通（新）

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

jsch channel

回答 2 投票 0

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

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

containers channel cics zos-connect-ee

回答 1 投票 0

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

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