concurrency 相关问题

在计算机科学中，并发性是系统的属性，其中可以在重叠的时间段中执行多个计算。计算可以在同一芯片中的多个核上执行，在同一处理器上抢占时间共享线程，或者在物理上分离的处理器上执行。

运行多进程时无法获取属性函数

我想比较使用多重处理和普通线性函数时的速度。我的代码看起来像这样来自多处理导入池、管理器导入时间从 faker 导入 Faker 行数...

python concurrency multiprocessing

回答 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

GoESL 与时间：呼叫并非源自 FreeSWITCH 中的某个点

我正在将 GoESL (https://github.com/0x19/goesl) 与 Temporal 集成，以通过 FreeSWITCH 自动拨号。该设置允许 1,000 个并发通道和每秒 50 个调用 (CPS)。每拨一个...

go concurrency freeswitch temporal-workflow

回答 1 投票 0

Java ExecutorService：- 当事件发生时通知线程唤醒

我有一个 Manager 类，多个线程向其中注册自己（使用 UUID 为每个请求生成唯一标识符），提供要处理的有效负载并从

java multithreading concurrency java.util.concurrent java-threads

回答 2 投票 0

如何将Python生成器转换为异步生成器？

我在Python中有一个生成器函数，它是IO绑定的。我想将其转换为异步生成器，其中生成器循环在单独的进程或线程中运行。最好，我想你...