multiprocessing 相关问题

多处理是在单个计算机系统中使用两个或更多个中央处理单元(CPU)

FastAPI/uvicorn 工作人员打印额外的打印件

我正在使用 FastAPI,并在脚本顶部(就在导入之后)有一个打印语句 print(“正在初始化应用程序...”)。这就是我运行应用程序的方式(在脚本本身中)- 乌维奇...

回答 1 投票 0

在cpp中执行python文件

我想在cpp中执行一个python文件,使其成为一个可以与我的其他子进程通信的进程。但是当我使用 execl("python3", "python3", "python/a1.py"...

回答 1 投票 0

Python 多处理 - 检测 PID 是否存活

我需要检测孙进程的PID是否还活着。因为 multiprocessing.Process() 对象是不可pickle的(出于安全原因),我无法将其传递到进程层次结构并调用

回答 1 投票 0

Python 多重处理的多个进度条

我使用带有专用“包装器”(我们称之为 sw)的 FEA 软件,以以下方式提供“不透明”模型处理程序 model = sw.Load("myfile.ext")。 为了保持跟踪...

回答 1 投票 0

Python 多处理器池后处理

我有一组要执行的任务(数以百万计),我必须发布每个“执行”的结果。 POST 为我提供了一种批处理结果的方法。 我有以下骨骼...

回答 1 投票 0

Presidio Framework 支持并行处理吗?

我正在使用 presidio 框架和 bert PII 模型进行 PII 检测。我尝试使用 ray 但无法实现并行处理。 presidio 是否兼容并行处理 我...

回答 1 投票 0

Python多重处理可以在“不相关”进程之间做信号量吗?

我正在研究多处理Python模块来保护一些需要原子访问(做一些事情)的硬件(内存映射)资源。 (硬件是一个 FPGA,实现了一些有限的

回答 1 投票 0

通过更新 url 重新连接 websocket 的最快方法

我需要从 binance api 接收一些数据。当硬币发生变化时,我需要更新 websocket 的 url。但我想花尽可能少的时间。为了避免主线程超载,我创建...

回答 1 投票 0

使用 imap 时如何向函数发送多个参数?

我想使用 pool.impa 对以下代码使用多重处理: # 相对强弱指数 def 预测(stock_symbol,date_confidences): stock_data = pd.read_csv(f'data/{stock_symbol}') # 计算 RSI

回答 1 投票 0

为什么在 Windows 上启动多个进程比在 Linux 上花费更长的时间?

请参阅以下Python代码。我使用多处理模块中的 Process 类来定义 Python 进程。 time1 是启动进程之前的时间,time2 是所有进程之后的时间

回答 1 投票 0

为什么Windows中多个进程需要2秒才能启动?

请参阅以下Python代码。我使用多处理模块中的 Process 类来定义 Python 进程。 time1 是启动进程之前的时间,time2 是所有进程之后的时间

回答 1 投票 0

为什么Windows中多个进程需要1秒才能启动?

请参阅以下Python代码。我使用多处理模块中的 Process 类来定义 Python 进程。 time1 是启动进程之前的时间,time2 是所有进程之后的时间

回答 1 投票 0

如何从Python中的多处理spawn进程异步获取数据?

我有一个带有单个端点/生成的 FastAPI 应用程序。该端点接收请求并将它们放入全局 input_queue 中。现在,名为worker的后台生成进程从

回答 1 投票 0

python 多处理 - 是否可以同时使用队列和事件?

我尝试以对我来说似乎非常简单的方式使用多处理队列和事件,但实际上并没有像我预期的那样工作。我的想法是有一个队列对象将任务传递给工作人员......

回答 1 投票 0

为什么 multiprocessing.starmap() 在虚拟函数上花费这么长时间?

我对 Python 中的多处理世界非常陌生。 作为实验,我编写了以下代码来了解多处理的好处。具体来说,我想尝试一下 sta...

回答 0 投票 0

使用 Lock() 运行 python 多处理

我有带有“pool.imap_unordered”的多处理脚本。 我想用 多处理.Lock() 你能写出以下脚本的正确使用方法吗? 导入多重处理 定义

回答 1 投票 0

如何在一定时间内使用多处理

我正在使用多重处理将 500k 消息发送到队列,但发送得太快,导致服务器宕机。 案例:for循环,发送500k条消息花了10分钟 如果是:多处理,它

回答 1 投票 0

如何根据工作结果向正在运行的多处理池添加额外任务?

假设我有一组 20 个 CPU 繁重任务(每个任务大约 1 小时,但有些需要更长的时间),这些任务是通过调用函数来运行的,例如Pool.apply_async(function, task_list) 等。 PC 有 12 个核心。这样我就可以...

回答 2 投票 0

Python 多处理池 'raise ValueError("Pool not running") ValueError: Pool not running' function with return value

我正在尝试并行运行在循环中有返回值的函数。 但在 for 循环的第二次迭代中,它似乎停留在 results = pool.map(algorithm_file.foo,population) 上 提高

回答 1 投票 0

多处理并将日期写入磁盘以减少Python中的内存成本?

我正在使用多处理来进行大量并行计算,并将结果作为列表返回。现在可能的问题是该函数经常耗尽内存。我当前的代码就像 定义

回答 1 投票 0

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