Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
multiprocessing.Pool.map_async 似乎没有做任何事情?
因此 我正在开发一个应用程序 该应用程序每次启动时都必须根据哈希列表检查约 50 GB 的数据 显然 这需要并行化 并且我不希望应用程序在 正在加载 屏幕上挂起一分半钟 我在用着multiprocessing Pool s map asyn
python
pythonmultiprocessing
Process.join() 和队列不适用于大量数据[重复]
这个问题在这里已经有答案了 我正在尝试拆分 for 循环 即 N 1000000 for i in xrange N do something 使用 multiprocessing Process 并且它适用于较小的 N 值 当我使用更大的
python
python27
pythonmultiprocessing
如何更改多处理模块使用的序列化方法?
如何更改Python使用的序列化方法multiprocessing图书馆 特别是 默认的序列化方法使用pickle具有该版本 Python 的默认 pickle 协议版本的库 默认的pickle协议在Python 2 7中是版本2 在Pyt
python
serialization
pickle
pythonmultiprocessing
使用 python 的多处理池和映射函数测量进度
我用于并行 csv 处理的以下代码 usr bin env python import csv from time import sleep from multiprocessing import Pool from multiproces
python
Multithreading
csv
parallelprocessing
pythonmultiprocessing
非阻塞 multiprocessing.connection.Listener?
我使用 multiprocessing connection Listener 进行进程之间的通信 它对我来说很有魅力 现在我真的很喜欢我的主循环在客户端命令之间做其他事情 不幸的是 listener accept 会阻止执行 直到建立来自
python
Sockets
Asynchronous
python33
pythonmultiprocessing
如何在超时后中止 multiprocessing.Pool 中的任务?
我正在尝试以这种方式使用 python 的多处理包 featureClass 1000 k 1 for k in drange start end step list of arguments for f in featureClass p
python
multiprocessing
pythonmultiprocessing
为什么 Python 中没有报告多处理错误以及如何打开报告错误?
我设置了一些简单的代码来测试多处理的一些问题处理 但我无法跟踪此代码中的错误 因为没有来自进程的反馈 既然现在我对它视而不见 我如何才能从子流程接收异常 如何调试这段代码 coding utf 8 import multiprocessin
python
pythonmultiprocessing
如何使用 OpenCV 使用多处理并行处理图像?
我的文件夹中有一组图像 我想使用一些 OpenCV 函数对其进行预处理 功能 detectAndaligncrop 使用 OpenCV 对其图像路径进行预处理并返回输出图像 我可以使用以下方法来做到这一点 for image path in
python
Multithreading
opencv
pythonmultiprocessing
os.fork 和 multiprocessing.Process 之间的行为差异
我有这个代码 import os pid os fork if pid 0 os environ HOME rep1 external function else os environ HOME rep2 external function
python
process
multiprocessing
fork
pythonmultiprocessing
如何与张量流保存的模型预测器并行进行推理?
张量流版本 1 14 我们当前的设置是使用张量流估计器进行实时 NER 即一次对一个文档进行推理 我们有 30 个不同的字段需要提取 每个字段运行一个模型 因此总共有 30 个模型 我们当前的设置使用 python 多重处理来并行进行推理
python
tensorflow
multiprocessing
pythonmultiprocessing
Ray
如何使用Python多进程apply_async获得精确的超时?
我正在使用多进程池并行运行一批作业 我想给每项工作2秒的时间限制 也就是说 如果一项工作花费的时间超过 2 秒 我想终止该工作并继续执行下一项工作 这是我的代码 from multiprocessing import Pool Timeou
python
pythonmultiprocessing
来自一个多处理管理器的多个队列
我正在编写一个将使用 python 的多处理和线程模块的脚本 为了您的理解 我生成了与可用核心一样多的进程 并且在每个进程中我启动了例如25 个线程 每个线程消耗一个input queue并产生output queue 对于我使用的队列对象
python
Multithreading
Queue
pythonmultiprocessing
了解多处理:Python 中的共享内存管理、锁和队列
多重处理 https docs python org 2 library multiprocessing html module multiprocessingpython中的一个强大的工具 我想更深入地了解它 我想知道什么时候使用regu
python
locking
multiprocessing
pythonmultiprocessing
scoped_session 中跨进程边界
我正在使用 SQLAlchemy 和多处理 我还使用scoped session 因为它避免共享同一个会话 但我发现了一个错误及其解决方案 但我不明白为什么会发生这种情况 你可以在下面看到我的代码 db py engine create e
python
Session
sqlalchemy
pythonmultiprocessing
Python 中的线程需要更长的时间而不是使其更快?
我编写了 3 个不同的代码来比较有线程和没有线程 基本上测量通过使用线程节省了多少时间 结果没有任何意义 这是我的代码 import time def Function global x x 0 while x lt 300000000 x
python
Multithreading
time
pythonmultithreading
pythonmultiprocessing
如何从 Pool.starmap_async() 获取结果?
我有一个程序可以计算 array value 的索引并返回一个字符串 我用 starmap async 因为我必须将两个参数传递给我的异步函数 该程序如下所示 import multiprocessing as mp from multip
python
Asynchronous
multiprocessing
pythonmultiprocessing
starmap
如何在 python 多处理中创建共享的二维数组
我需要使用 python 的多重处理来处理一个大矩阵 这就是说我需要二维数组 该数组应该由不同的子进程以同步方式共享 访问 更新 因此我使用mp Manager 在创建数组时 multiprocess Array 让我创建一个一维数组 我尝
python
NumPy
pythonmultiprocessing
用于多处理日志记录的 QueueHandler
我正在尝试调整我的程序以将不同进程记录到单个日志文件中 我已经寻找解决方案很多天了 但没有成功 我想我仍然不明白队列处理程序是如何工作的 在我看来 这个过程是这样的 create q 将 qHandler 添加到主记录器 所有日志都将重定向
python
logging
pythonmultiprocessing
pythonlogging
如何使Python的多处理队列的.empty()方法返回正确的值?或者替代方案?
我有这个片段使用Queue类来自multiprocess模块 我很困惑 empty 实例的方法Queue没有给我一个正确的值 正如我所期望的那样 这是我的代码 from time import sleep from multiprocess
python
Multithreading
python27
pythonmultiprocessing
«
1
2
3
4
5
6
7
8
»