1回答
为每个消费者创建一个不同的队列会是个好主意吗？通过这种方式，生产者以循环的方式在每个队列中添加作业，并且访问单个队列没有延迟。
我使用Python3.7和多线程/多线程处理来创建多个使用者。我目前已经用多进程和单队列开发了它，但是我正在考虑改变多线程和多队列的方法。单
浏览 10提问于2021-02-11得票数 1
回答已采纳
4回答
我如何在Python中实现这一点？Update0
此外，我不确定Python的队列是否能做到这一点。
浏览 5提问于2011-12-10得票数 12
回答已采纳
3回答
有没有消息传递解决方案(最好支持Python)，我可以像邮箱一样使用，例如，从任何给定的队列中检索消息，而不必订阅？我认为消息队列可以工作，但我必须重复订阅，从队列中抓取消息，然后取消订阅，这听起来并不是最优的。
浏览 1提问于2011-03-30得票数 0
回答已采纳
有3个守护进程线程的应用程序和4个单独的应用程序(多处理队列/管道和从队列/管道应用程序读取的3个守护进程线程应用程序)在线程操作功能上是否有区别？
浏览 0提问于2016-10-21得票数 0
1回答
void MultiQueue(int k){ }
我需要创建一个可以在其中存储多个队列的多队列我将创建两个构造函数来构建多队列。其中之一是创建一个只有一个队列的多队列，另一个是创建k个队列(依赖于用户)。我该怎么做呢？
浏览 3提问于2016-11-12得票数 0
我想让我的一些通用代码通过python2.7和python3.6版本工作。此问题仅发生在队列模块的一个模块导入中。在Python2.7：from Queue import Queue中试图在import部分中执行如下操作：
try:
浏览 0提问于2018-06-26得票数 2
回答已采纳
1回答
1.push to the Queue我想在同一时间推拉队列，但我不确定(我没有在文档中找到，也没有找到实现)，队列是否保护了对同一内存访问的冲突 There is zero elements in the Queue -> Ipush and then I pull in the same time
我的问题是，如果队列没有保护它，有什么办法只锁定入口或出口的队列？
浏览 0提问于2019-04-02得票数 0
回答已采纳
1回答
我在找一个用python写的amqp broker。现在，我正在使用带有pika绑定的。RabbitMQ可以完成这项工作，但如果能找到用python编写的更简单、更轻量级的代码就更好了。但它(还)不支持多队列，这在我的例子中是必需的。
有没有人知道有没有用python编写的替代方案？
浏览 3提问于2012-11-15得票数 3
我想创建一个包含大约256K个文件路径的队列，并让这些路径出列并由并行工作进程处理。这是多进程，而不是线程。然而，当我创建一个multiprocessing.queue时，队列中似乎有一个32K对象的硬限制。如果对象如预期的那样是文件的完整路径，则该值可能更小。创建用于多处理的多服务器队列的替代方法是什么？ElectionTransparency/vops_addons/dead/tryq.py", line 13, in <module>
q.put('
浏览 12提问于2019-04-09得票数 0
回答已采纳
1回答
据我所知，often队列将被检查比default队列多2倍，比seldom队列多4倍？如果我要添加一个重量为100的队列呢？
浏览 2提问于2014-01-20得票数 5
回答已采纳
我想用pip安装mailer库，但是它导入了模块Queue，在python 3中重命名为queue，我怎么用pip下载它呢？
浏览 2提问于2014-10-10得票数 0
我试图找出在不同程序之间发布和接收数据的最佳方法。我的理想设置是让一个程序不断地从外部websocket接收市场数据，并让多个其他程序使用这些数据。由于这是来自交易所的市场数据，管理费用越低越好。
浏览 0提问于2017-09-15得票数 0
回答已采纳
我注意到本文：
在另一个线程中，我读取raw队列，进行预处理，并将其加载到ready队列中。在我的主线程中，我从ready队列中抽取了8组图像，并通过tensorflow培训运行它们。对于批处理的8幅图像(每个~25 24的numpy矩阵)，在当前处理和两个队列之间的任何给定时间内，我应该至少
浏览 3提问于2017-04-08得票数 2
回答已采纳
我正在尝试从Cocoa应用程序运行Python脚本。它在主线程上工作得很好，但我希望它在后台运行，在并发的GCD队列上运行。我使用以下方法来设置一个运行Python脚本的管理器类： if (Py_IsInitialized()) return YES;classmethod return run_with_arguments(arguments)
当我总是从主<em
浏览 0提问于2012-01-14得票数 16
回答已采纳
我正在考虑利用动态后端来做一些大规模的推送任务队列式的作业，这些作业需要比10分钟稍长一点的时间来处理。基于我的任务队列量的动态后端的按需和“自动缩放”的能力是非常有吸引力的。在将这些队列配置为“target”为“None”时，这会导致这些队列使用前端实例进行处理。由于我将Python27与threadsafe结合使用，这使得我的任务可以在更少的实例上由多个线程处理。理想情况下，我希望在同一个后端上运行20个后端实例，但同时运行尽可能多的“请求”。
问题是:后端是这样做的吗？
浏览 2提问于2012-07-20得票数 1
回答已采纳
3回答
我目前正在为我们系统中的作业寻找一种新的队列系统。我试过豆茎，但它跟不上负载。我正在寻找一个简单的系统来启动和运行，我可以将来自生产者的数据片段放入其中，并让Java、PHP和Python中的消费者提取并处理数据。理想情况下，我希望看到如下功能：Priorities ->排定作业优先级的能力
多通道->能够使用一个队列为多个具有独立数据流
浏览 3提问于2010-09-06得票数 4
1回答
在我的Linux系统中，我看到了以下内容：........在指南中的示例中也有qdisc noop和qdisc noqueue，但没有关于它们的详细信息。
浏览 0提问于2013-01-31得票数 5
回答已采纳
如果我的应用程序中有内存密集型和算法密集型的部分，我会希望用C或Java来实现它们。将此代码连接到我的Django/(Rails、Merb等)的最佳方式是什么？web应用程序？
浏览 4提问于2011-03-12得票数 0
回答已采纳
TLDR:无法在multiprocessing.Queue中传递堆栈跟踪，当我在该队列中传递错误时，一旦在消耗队列的其他工作人员(线程或进程)中接收到它们的堆栈跟踪，它们的堆栈跟踪就会被剥离。我如何传递堆栈跟踪，以便在它的使用者队列的另一端还原它？
那么假设我有两个Python工作人员。这两名工人是同一类型的。我使用一个multiprocessing.Queue在工作人员之间传递数据，最后一个主线程轮询队列以获取所有信息，以便在结束时加入并关闭所有内容。如果主线程从队列接
浏览 13提问于2022-06-23得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
