有没有办法让ProcessPoolExecutor在所有工作者都很忙的时候有一个有界的队列来处理传入的请求？
在文档中，没有解释如果调用submit()并且所有工作进程都很忙时会发生什么。然而，我做了一些研究，发现ProcessPoolExecutor有它自己的内部队列，显然是无界的。一般来说，使用非绑定队列不是一种好的做法，因为Executor可能被用来使系统崩溃(DoS攻击)。
浏览 21提问于2020-02-20得票数 0
1回答
我在python2.7中使用带有concurrent.futures库的队列。当我在下面运行这个代码片段时，它打印4个1的情况并不少见。我希望线程队列是一种共享数据的方式，但它似乎不安全。print x
for x in [1,2,3,4,5]: #with concurrent.futures.ProcessPoolExecutor(max_workers=2) as execu
浏览 2提问于2016-03-21得票数 0
回答已采纳
我在ThreadPoolExecutor中使用ThreadPoolExecutor作为工作队列。问题是我应该使用有界LinkedBlockingQueue还是无界LinkedBlockingQueue。我已经重写了ThreadPoolExecutor的执行方法，不再面临在内核池大小之后创建线程的问题。谢谢你，图沙尔
浏览 10提问于2013-10-15得票数 8
回答已采纳
免责声明：我一般都是刚接触过的。我有一个关于Go的小体验，在那里使用通道实现队列是非常容易的。或者是否有更好的方法在多个进程之间共享列表/队列
浏览 0提问于2018-09-24得票数 4
回答已采纳
2回答
我正在尝试使用下面的示例使用并发期货，但我的工作从未提交过。在load_url中看不到print stmt。manager = multiprocessing.Manager() q = queue.Queue()
with futures.ProcessPoolExecutor
浏览 19提问于2019-08-09得票数 1
1回答
请注意，我不是在谈论任何特定语言的特定实现。下面的线程池配置容易出现什么类型的问题(例如死锁)？我关心的可能的线程池配置：
1) num有界的无界任务<e
浏览 1提问于2011-02-18得票数 0
我正在创建一个django the服务器，允许用户在本地机器上运行一些“可执行文件”，并通过网页分析它们的输出。
我以前使用过芹菜任务队列，以便在类似的情况下运行“可执行文件”。然而，在阅读了Python之后，我开始怀疑是否应该使用，或者ProcessPoolExecutor (或者ProcessPoolExecutor：d中的ThreadPoolExecutor )来代替？因此，我应该使用芹菜或PoolExecutor作为我的简单的why服务器，为什
浏览 3提问于2016-05-18得票数 13
回答已采纳
这是我关于stackoverflow的第一个问题。我基本上可以在这里找到我需要知道的东西。顺便说一句，非常感谢你。
然而。如果我试图杀死我的ProcessPoolExecutor，它将只在生成的整个队列中工作(..我想是吗？)。有什么简单的方法可以立即清除Processpoolexecutor的队列吗？from concurrent.futures import ProcessPoolExecutor</em
浏览 0提问于2017-12-31得票数 3
1回答
我需要制作一个有界队列的字典。以下是我到目前为止所掌握的。collections import defaultdict...创建一个有界队列：q = deque(maxlen = 10)可以工作，但当队列在字典中时，我不确定该如何做。有人能帮我画一张有界队列的地图吗？
浏览 0提问于2012-12-20得票数 0
回答已采纳
1回答
我使用的服务器有4个内核和8 8GB内存。在没有任何多线程的情况下，完成任务大约需要5分钟。 现在，我正在尝试设置多处理测试，并使用服务器上的4个核心，但没有取得任何结果。
浏览 17提问于2020-08-26得票数 1
我将围绕RabbitMQ队列制作一个域驱动的设计，我对此完全陌生。我想知道，考虑到有限制的上下文，是否有一些准则来识别不同的队列。内容，如每个有界上下文中的一个队列，或有界上下文中的每种资源类型中的一个队列。有什么建议吗？
浏览 0提问于2019-05-18得票数 3
回答已采纳
3回答
有界上下文和基础结构关系
、、、
根据我对ddd的理解，服务是围绕有界上下文进行理想定义的。这些服务之间的交互反映了它们各自有界上下文之间的关系。这是我关注的一个问题，因为我们非常关注应用程序基础结构堆栈是如何相互依赖的。例如，我们试图避免两个独
浏览 20提问于2022-04-13得票数 2
但是，当我通过时，我看到了这一点：
有界</em
浏览 16提问于2012-08-06得票数 9
回答已采纳
1回答
python中的有界队列
、、、
如果我想创建一个有界限的队列，但又想在函数内部为队列创建界限，而不是使用类BoundedQueue.Queue(maxsize = 4)，该怎么办？(有关最大绑定队列的信息：)
有什么建议吗？这是我的代码；capacity是最大界限。
浏览 3提问于2013-02-13得票数 0
我已经创建了一个优先级队列，并用项目填充了该队列，并以此队列为基础，对其进行了迭代，找到了项目的优先级。根据优先级，我使用一些逻辑将项目移动到子队列。在我的主程序中，我使用静态语句创建了有界子队列，我想做的是使用父队列构造器的构造函数创建有界子队列：public HiLoPriorityQueue(int high_capacity, int low_capacity)构造函数应该
浏览 0提问于2015-11-20得票数 0
我正在尝试使用新的对象和，以允许我的new服务器将cpu密集型任务传递给其他进程。我希望访问从Future模块从ProcessPoolExecutor返回的ProcessPoolExecutor对象，以便能够查询其状态以显示在前端(例如，显示当前正在运行的进程；显示它已经完成)。对于这种方法，我似乎有两个障碍：
如何在访问返回的q.get()对象的同时向ProcessPoolExecutor提交多个Future对象？如何让Home
浏览 1提问于2015-11-05得票数 1
回答已采纳
2回答
我已经看到了线程池执行器的实现和它提供的拒绝的执行策略。但是，我有一个自定义要求--我想要有一个回调机制，当队列大小达到限制时，我会收到通知，当队列大小减少到最大允许队列大小的80%时，通知我。// called when blocking queues size goes below the threshold.我觉得这可以通过将线程池executor子类化来实现，但是有没有已经实现的版本呢我很乐意在需要的
浏览 2提问于2011-10-04得票数 1
回答已采纳
1回答
我很难在python中使用多处理，尽管我没有在任何平台上使用过多处理，也不清楚队列在多进程通信中是如何工作的。(如果有人能提供一个简单的参考，那将是很大的帮助)。出现问题： def __init__(self):
self.bla_exec = ProcessPoolExecutor(max_work
浏览 3提问于2020-10-28得票数 0
回答已采纳
我有两个函数，需要返回值才能继续script...but的进一步部分，目前我的代码只给出了第一个函数的输出.def gm(name): p2.start() p2.join()#输出-“阿辛早安”感谢你的帮助
浏览 7提问于2021-12-07得票数 0
1回答
我正在使用这个有界优先级队列https://gist.github.com/ryanlecompte/5746241的实现，它工作得很好。但是，我希望这个队列不包含任何具有相同排序'ord‘的元素。+=(a) } 但我认为它不起作用，因为与新元素具有相同顺序的元素可能不在头部。有什么可以快速解决此问题的方法？ 非常感谢。
浏览 18提问于2019-03-10得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
