multiprocessing 相关问题

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

Python 函数适用于 Process,但不适用于 apply_async

从脚本导入classify_reads 从多处理导入值、流程、池 从 multiprocessing.managers 导入 BaseManager 我有一些使用多处理功能良好的代码(python

回答 1 投票 0

所有多处理生成都重新运行已完成的代码。应该只运行他们的功能

也许我不明白多重处理是如何工作的,但请帮助解决以下问题。 我的程序在启动时运行一些繁重的进程,以整合多处理功能的数据。 ...

回答 1 投票 0

从已完成的多处理任务中检索结果

我需要运行数十个计算密集型 CPU 密集型并行任务。目前我使用 joblib 延迟和并行来执行此操作: resultTuples = 并行(n_jobs=-1,更喜欢=“进程”)(del...

回答 1 投票 0

在多核上从 scikit-learn 运行 LinearRegression() 时出现问题

我想在 5 个核心上运行 sklearn 库中的 LinearRegression()。正如文档所说,除非 n_targets > 1,否则 n_jobs 参数不会导致多重处理,我创建了随机数据...

回答 1 投票 0

将master类的状态传递给另一个进程中的worker

我想与多个工人分享大师班的状态。为了实现这一目标,我创建了一个 Master 和 Worker 类。工作人员由 eel 跟踪的一个简单按钮触发。 我的工人

回答 1 投票 0

如何同时运行具有异步函数的类的多个实例?

类计算(): def __init__(自身, 值): 自我价值=价值 异步定义一个(自身): 而真实: print(自身值 * 1) 等待 asyncio.sleep(1)

回答 1 投票 0

使用多个类对象进行多重处理

我有不同的Python类,它们都有一个名为push的方法。我正在尝试的是 创建多个类对象,每个类对象一个 调用推送方式 所有这些方法都应该执行...

回答 1 投票 0

ProcessPoolExecutor 使用地图挂在大负载上

仅在负载相对较大时,才会在地图上体验挂起运行 ProcessPoolExecutor 的情况。 我们看到的行为是,经过大约 1 分钟的努力工作后,作业似乎挂起:CPU 利用率...

回答 2 投票 0

如何等待python中的multiprocessing.connection.Client可用?

我有一个process.py脚本: 从 multiprocessing.connection 导入监听器 使用 Listener(('localhost', 6000)) 作为监听器: 使用listener.accept()作为连接: 消息 = 连接.r...

回答 1 投票 0

如何在Python的子进程中显示图像?

我正在研究光学表征,为此我需要同时显示图像和拍照。为此,我创建了一个处理显示并拍照的子进程......

回答 1 投票 0

使用多处理和异步的 TTS 服务中的 WebSocket 意外关闭

我正在Python中使用多处理和异步开发TTS(文本转语音)服务。我的主要应用程序使用队列集成其他组件。 但是,我遇到了一个问题,其中

回答 1 投票 0

将数据获取到manager.dict并在进程之间共享

我目前正在尝试自学如何通过将 Forza 遥测数据从 xbox 传输到我的 PC 来处理实时数据。我在将该数据存储在 manager.dict 并将其共享给其他人时遇到问题

回答 1 投票 0

python 协程和 while 循环,如何运行两者

我正在尝试一起运行两个协程并使用异步,一个是 teleton 电报客户端,一个异步任务每分钟为电报机器人获取数据。一些代码: 从 asyncio 导入 Runner 来自

回答 1 投票 0

如何在子守护进程中初始化 Pool(),但只能初始化一次?

在 python 3.11 和 Ubuntu 上,我有一个任务是每次间隔(不是 asyncio)初始化异步调用,并且在子进程内部执行多处理任务。我有 36 个核心/72 个处理器。问题是当我...

回答 1 投票 0

Python 中自动调用修饰函数时出错

有一个Python代码包含一个singleton_process装饰器和一个可解码的hello函数。装饰器旨在防止在另一个终端/进程中重新运行脚本。 来自

回答 1 投票 0

如何关闭进程内的多处理池?

我想知道如何使用异步调用(不是asyncio lib)在python(3.11)中进行多重处理,并在进程完成时自动关闭进程? 下面我写了一个简单的代码和p...

回答 1 投票 0

Python 进程类型错误:由于非平凡的 __cinit__ 而没有默认的 __reduce__

从aiohttp导入web 从 aiortc.mediastreams 导入 MediaStreamTrack 从 aiortc 导入 RTCPeerConnection、RTCSessionDescription 从 aiortc.contrib.media 导入 MediaPlayer 从 pydub 导入

回答 3 投票 0

如何通过按键随时中断 if 语句

我正在尝试为游戏(没有本地排行榜或比赛)制作一个机器人,其中机器人将根据时间和位置执行一系列动作。有时这些序列会很长......

回答 1 投票 0

注释掉一条打印语句时,多处理代码的行为有所不同

这是我的代码: 从随机导入随机 来自多处理导入过程 从多处理导入队列 导入时间 def new(shared_queue): print('消费者:正在运行',flush=True) w...

回答 2 投票 0

在 Multiprocessing BaseManager 类中填充列表实例

我正在尝试创建一种使用多处理模块将数据类对象传递给多个不同子进程的方法。现在我已经尝试过: 导入队列 从多处理导入过程,...

回答 1 投票 0

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