回答情况：
提问时间：
问题标签：
我正在尝试做一些实时(类似于)网络摄像头的视频处理。为了获取所有的帧并对其进行处理，我将帧采集器和图像处理器作为两个独立的进程运行。为了让他们交流，我试图在使用Python2.7的multiprocessing.queue和multiprocessing.pipe之间做出选择。
浏览 0修改于2018-12-27得票数 0
我在巨蟒中潜入多处理世界。此函数包含4个参数：# process_data(file, signals_dict, parameter_dict, debug_mode=False)t1 = time.time() executor.map(process_data, file_list)
t2 = time.tim
浏览 1提问于2020-05-13得票数 1
回答已采纳
我目前正在尝试从多个进程中记录到单个文件，但我遇到了很多问题。我花了无数的时间在网上寻找-- stackoverflow和谷歌，但没有找到任何具体的东西。我一直在尝试使用zzzeek的代码，但它不能为我写入文件。我没有具体的方法--我只是尝试了所有我能做到的方法。谢谢
浏览 0修改于2017-05-23得票数 0
回答已采纳
from multiprocessing import Pool
def __init__(self): self.count += ia.multiprocess我不知道multiprocess.Pool.map是如何工作的，它是如何与类协作的。请详细告诉我。
浏览 4提问于2021-11-24得票数 0
回答已采纳
我本来希望做一些类似multiprocess.spawn的事情，但我需要最后一个进程来返回设备编号，这样就可以清楚地知道哪个设备是打开的，可以在上面运行。
浏览 3提问于2022-09-23得票数 0
回答已采纳
我正在编写一个迁移程序，使用Perl和MongoDB将一个数据库集合中的数据转换为另一个数据库集合。数以百万计的文档需要转换，性能也很差(这需要几周的时间才能完成，这是不可接受的)。因此，我想使用并行：：TaskManager来创建多个进程来并行地进行转换。性能从OK开始，然后快速下降，然后我开始得到以下错误： at /usr/local/share/perl/5.18.2/Meerkat/
浏览 5修改于2016-01-13得票数 1
回答已采纳
我希望使用多进程从子进程中获得结果，然后将这些结果赋给变量的数组类型。for (( i=0; i<${#servers[@]}; i++ )); output_strings[$i]=$(ls) & done
wait $pid但是，结果没有分配到数组中。
实际上，如果我将代码output_strings$i=$(ls)
浏览 0提问于2018-10-08得票数 0
我希望并行执行任务，如果任务退出时有错误，那么所有进程都应该停止并退出。这是我的密码import time, os, subprocess, sys
pid = os.getpid() print("Death process (%d) 7 starts ..." % pid)
浏览 5修改于2021-01-22得票数 1
回答已采纳
我试图用简单的代码测试multiProcess Procee类。下面是简单代码和例外情况。
浏览 4提问于2015-10-11得票数 0
回答已采纳
我生成一个子进程，它简单地将数据从一个队列复制到另一个队列。问题是:在子进程的目标函数返回后，子进程似乎不像预期的那样存在。它挂在pdet.join()线上。import numpy as np i = 0 im = np.zeros((480, 640, 3), 'uint8') print(i)
浏览 1提问于2022-07-22得票数 0
我想在按Ctrl-C时终止我的程序，代码如下：# encoding: utf-8
import timeimport sys
signal.signal(signal.SIGINT, signal.SIG_IGN)
while(True): print "Working..."
if __name__
浏览 7提问于2016-01-28得票数 0
args, **kw) for x in range(2)]如何正确包装multiprocess.apply_async
浏览 0提问于2013-04-26得票数 9
回答已采纳
我有大量的对象需要迭代，我认为多处理将大大加快工作的速度。然而，这个简单的例子似乎挂起，一旦我增加核心计数。是什么导致它挂起来的？import time
time.sleep(1) # Simple code standing in for more
浏览 2提问于2020-07-26得票数 1
回答已采纳
尝试通过multiprocessing.Process中的getattr()调用say_hello和say_world两个方法，但尚未执行say_world方法。我怎么才能让它成为可能呢？谢谢。from multiprocessing import Process def say_hello(self): print('World')
c
浏览 2提问于2017-12-19得票数 0
series~/anaconda3/lib/python3.6/site-packages/multiprocess
浏览 2提问于2018-04-24得票数 6
我正在使用异步获取网页。以下是代码： res = await session.request(method="GET", url=url) async with ClientSession() as session:
tasks = [get_page_url(url, session) for province, u
浏览 1提问于2019-03-29得票数 2
回答已采纳
在multiprocessing.Pool中，我试图以同样的顺序显示我的指纹。import time time.sleep(0.001)proc_pool.map(func, range(30))我知道imap能给出更好的订单
浏览 0修改于2015-06-28得票数 4
回答已采纳
import psutilpool = Pool(psutil.cpu_count(logical=False))文件"C:\Users\AppData\Local\Continuum\anaconda3\lib\site-packages\multiprocessfunc，iterable，mapstar，chunksize).get()
文件"C:\U
浏览 3修改于2020-02-18得票数 0
回答已采纳
我需要通过迭代数据来获取非常大的数据块。总之，我需要几百万次迭代。所以我原以为压制会加快我的进程，但它几乎做到了。我使用subprocess.Queue调用不同的线程，这实际上很好，但是当我调用*subprocess.Queue.get()时，程序需要花费很长时间才能得到结果。也许我做错了什么。下面是我的最小示例： return_dict = {} process_list = []
# Create quese def
浏览 1修改于2018-12-04得票数 2
回答已采纳
我有一个处理字符串的函数，并将它应用于dataframe列。import numpy as npdef test_upper(d): df = pd.read_csv("file.csv", sep='\t', encoding='utf-8')
df['upper_co
浏览 3修改于2021-08-09得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号