使用Python多处理，我想捕获进程，丢弃它们，然后继续下一个进程。 在下面的例子中，我有一个1和0作为输入的列表。0将启动休眠功能以触发超时错误。触发超时的进程将重新执行，因此脚本将永远运行。如何捕获TimeOut错误，终止导致该错误的进程，并防止该进程重新执行？重要的是我可以使用imap来做这件事。= [1, 1, 0, 1, 1, 0]
with mp.get_context(&qu
浏览 43提问于2021-11-11得票数 0
回答已采纳
我想使用TimeoutError和tqdm进度条来执行多处理。目标：
return obj
with P
浏览 2提问于2019-06-05得票数 2
2回答
我做了很多关于多处理的研究！基本上，我从API下载数据并插入到数据库中。但是pool.join(超时值)返回"TypeError: join()正好有一个参数(2给定)“。我想唯一的论点是默认的“自我”？代码的一小块：pool = Pool(10)
in_tuple = [x for x in pool.imap(multi_det
浏览 0提问于2018-09-05得票数 1
回答已采纳
进程在字节块上运行。我正在尝试使用使用多处理的并行处理来提高性能。最初我尝试使用pool.map，但这只允许单个参数，然后我发现了pool.starmap。但是，pool.starmap只在所有进程完成后才会给出结果。我希望结果来了(某种程度上)。我试图使用pool.imap，它确实在进程完成时提供结果，但不允许多个参数(我的函数需要2个参数)。这就是为什么我尝试使用pool.imap的原因，它工作得很好，但只有一个参数：
pool = mp.Pool(processe
浏览 13提问于2015-09-11得票数 18
回答已采纳
3回答
需要：
在Python 3.5.2上运行。Python3子流程模块内置了，我也尝试过使用计时器和线程实现超时，但是它不能处理输出。rea
浏览 8提问于2016-08-06得票数 6
我对托管web应用程序有点陌生，但我有一个运行中的Python应用程序，它使用mod_wsgi部署在apache服务器上的webpy。
浏览 1提问于2013-10-17得票数 0
回答已采纳
1回答
我正在使用Python2.7.10函数轮询数据，如果设备响应时间太长，我希望超时，或者如果设备不可用，则捕获RuntimeError。我正在使用这个超时函数： class Timeout(Exception): def __init__local_vals.append(None)这将一次工作几天，没有任何问题，RuntimeErrors和超时都
浏览 1提问于2019-03-05得票数 2
1回答
我们正在使用azure服务总线通过监听队列的工作进程来促进消息的并行处理。首先，接收聚合消息，然后将此消息拆分为数千条单独的消息，这些消息通过请求-响应模式发布，因为我们需要知道所有消息何时都已完成以运行单独的进程。我们的问题是请求-响应方法有一个超时，这导致了以下问题：
假设我们发布了1000条要处理的消息，并且只有一个worker在监听。超时到期后留在队列中的消息将被丢弃，这是我们不希望看到的。如果我们将过期时间设置为一个较大的值，以保证所有消息都会得到处理
浏览 0提问于2016-07-06得票数 0
2回答
然而，在django的上下文中，这更像是一个Python通用问题。
目前，我在django中有这个视图，它必须处理大量数据。通常这需要服务器(nginx和django在代理中运行)几分钟来完成。有时服务器会超时。我不想增加nginx中的超时时间。我意识到，如果我可以在django视图中使用python派生一个进程，这样派生的(子)进程将独立于django视图执行所有数据处理，那么视图将能够立即将请求返回给用户(因此永远不会超时)，并且
浏览 2提问于2012-02-06得票数 4
回答已采纳
3回答
多处理和垃圾收集
、、、
.): return pool.imap(...)然而，对于2.7.2版本的标准Python实现，这种方法很快就会导致"IOError: Errno 24太多打开的文件“。显然，pool对象从不进行垃圾回收，因此它的进程永远不会终止，无论内部打开什么描述符，它都会累积起来。pool.terminate()我希望保留imap的“惰性”迭代器方法；在这种情况下，垃圾收集器是如何工作
浏览 3提问于2012-04-01得票数 13
回答已采纳
我正在尝试学习如何使用Python的多处理包，但我不明白map和imap之间的区别。
比如说，map返回的是实际的数组或集合，而imap返回的是数组或集合上的迭代器吗？这是传递给每个进程的值的数量吗？
浏览 2提问于2012-07-05得票数 51
回答已采纳
the print pool = mp.Pool(processes=1) File "/Users/usualme/anaconda/lib/python2.7/multiprocessing/pool.py", line 659, inraised AFTER
浏览 3提问于2014-10-09得票数 2
回答已采纳
或者换句话说，我只想让脚本收到新消息的通知，这样我就可以立即处理它，而不是轮询之间的任何滞后时间。我看到IMAP协议通过IDLE命令支持这一点，但是我在imaplib文档中看不到任何与此相关的文档，所以在这方面有任何帮助就太好了！
浏览 2提问于2009-01-07得票数 26
回答已采纳
我有一个python脚本，它在下班后在服务器上运行，并调用许多shell子进程。被调用的程序都不应该是提示性的，但有时会发生这种情况，脚本会挂起，等待输入，直到用户(我)注意到并生气。:)我不想对提示做出响应，我想让脚本抛出一个错误并继续。有什么想法吗？
谢谢，亚历山大。
浏览 0提问于2011-02-28得票数 1
python进程正在写入文件，该文件已被外部进程删除/移动(在我的例子中是cron作业)。python进程将继续执行，不会出现任何错误(因为它将被写入缓冲区而不是文件，并且将在f.close()之后刷新)。然而，在本例中不会创建任何新文件，缓冲区将被静默丢弃(如果我错了，将纠正我)。在每次写入操作之前，是否有任何pythonic方法来处理这个问题，而不是检查是否存在文件并创建一个文件。
浏览 9提问于2019-09-27得票数 4
回答已采纳
skraafoto/aerial_photos_scraper.py", line 228, in <module> File "/usr/local/lib/python3.7asyncio/runners.py", line 43, in run File "/usr/local/lib/
浏览 0提问于2019-05-23得票数 4
回答已采纳
Python程序，带有一个shebang。此子进程的持续时间可能比指定的timeout长。子进程在文件中进行大量计算和写入结果，并且不包含任何信号处理程序。根据文档的说法，subprocess.run杀死了一个超时的孩子：
超时值参数被传递给Popen.communicate()。如果超时过期，子进程将被终止并等待。当我的子进程超时时，我总是收到subprocess.TimeoutExpired异常，但有时该子<e
浏览 10提问于2022-11-21得票数 0
好的，所以我从来没有使用过python多处理库，而且我也不知道如何使用我的搜索。我读了图书馆的文档，我试着寻找我的问题的例子，却什么也找不到。我想在每个处理器上运行我的函数，每次函数运行时都使用一个文件名作为变量。所以我希望它运行4个进程，每个处理器运行1个，当一个函数结束时，它会传递到列表中的下一个项，而每个函数都将更新一个共享字典。r") cond[fnom] = otherfunc(r)
浏览 2提问于2014-01-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
