-
0 votesanswersviews
在SEDA上设置queueSize选项
我有一个seda队列，我根据camel documentation设置queueSize选项 我的路线看起来像： from("seda:someQueue?concurrentConsumers=10&queueSize=10") .process(someProcessor); 由于queueSize选项，我收到以下错误： org.apache.camel.Fail... -
0 votesanswersviews
在Anylogic中添加/注入代理到队列
我在Anylogic中有一个混合模型，我的一些代理必须将部件（也是代理）添加到离散事件模拟队列中 . 从队列中获取代理是通过 queue1.removeFirst(); 完成的，但我可以't seem to find the equivalent to add something. I'尝试 addAgentToContents 但没有运气... -
0 votesanswersviews
根据客户的类型排队进出
根据客户类型问题进出队列 根据以前的实现，修改LIST命令，使其先按队列号按升序打印VIP客户端，然后按普通客户端打印 . 与OUT命令相同，VIP将首先排队到普通客户端 . Input IN 1000001 Ordinary IN 2000003 VIP IN 2000009 VIP OUT OUT OUT OUT IN 1000007 Ordinary IN 2000005 V... -
0 votesanswersviews
jboss 6远程jms网桥配置无法正常工作
我必须从一个jobss服务器推送消息并从另一个jboss服务器消费 . 为此，我使用了jms桥 . 在 standalone-full.xml 中添加了</ hornetq-server>标记下的jms网桥配置，并通过模块引用了依赖关系 . <jms-bridge name="simpleBridge" module="org.jboss.messa... -
4 votesanswersviews
多个 生产环境 者单个消费者队列
我是多线程的新手，他设计了一个程序，从两个微控制器接收数据，测量各种温度（环境和水），并将数据绘制到屏幕上 . 现在该程序是单线程的，它的性能很快 . 我得到了多线程的基本设计方法，但不足以创建一个执行任务的线程，但我没有得到的是如何让线程执行单独的任务并将数据放入共享数据池 . 我想我需要创建一个具有一个使用者和多个生成器的队列（想要使用std :: queue） . 我在gtkmm线程文档中看... -
5 votesanswersviews
使用未知大小的队列的Web爬网程序的 生产环境 者/使用者
我需要抓取父网页及其子网页，我遵循http://www.albahari.com/threading/part4.aspx#%5FWait%5Fand%5FPulse的 生产环境 者/消费者概念 . 另外，我使用5个线程将链接排队和出列 . 有关如何在队列长度未知的情况下，如果所有线程都已完成处理队列，我将如何结束/加入所有线程？ 以下是关于我如何编码的想法 . static void Main(... -
15 votesanswersviews
Python线程和队列示例
我'm new to python (I come from PHP), I'已经阅读了教程并尝试了几天，但我无法理解这个队列示例（http://docs.python.org/2/library/queue.html） def worker(): while True: item = q.get() do_work(item) q.task... -
0 votesanswersviews
使用MSMQ队列来分离消息 生产环境 者和消费者？
对于将报告发布到SOAP服务的一些Windows服务（c＃），我将不胜感激 . 它从数据库中获取一组有限的报告（Oracle AQ表中的报告），将它们聚合到一条消息中，并将此消息转发给WCF SOAP服务 . 如果已成功通过SOAP传输报告，则会将其标记为“已发送” . 否则，它们将再次添加到AQ表（通过db作业） . 所以我提出了以下设计 . 什么是最好的方式去？队列是否会在可扩展性，稳健性，解... -
0 votesanswersviews
Python多线程/队列生成器和消费者竞争问题
我有以下python代码，每个线程正在执行以下角色 . 制片人 - 生成json文本Processor-解析json并生成json对象列表消费者 - 获取列表并持久保存到数据存储 生产环境 者发送json和消费者获取json列表，问题是消息计数从 生产环境 者到消费者不匹配 . 一些消息正在消失之间 . 我看到生成器和解析器之间的消息计数是同步的 . 已解决：我必须在将它们发布到队列/列表后创建新... -
53 votesanswersviews
使用队列的 生产环境 者/消费者线程
我想创建一些 Producer/Consumer 线程应用程序 . 但我不确定在两者之间实现队列的最佳方法是什么 . 所以我有两个想法（两者都可能是完全错误的） . 我想知道哪个更好，如果它们都吮吸那么什么是实现队列的最佳方式 . 这主要是我在这些例子中实现的队列，我很关心 . 我正在扩展一个内部类的Queue类，并且是线程安全的 . 以下是两个示例，每个示例包含4个类 . 主类 - public... -
1 votesanswersviews
在python多 生产环境 者和多用户线程中，queue.join（）可能不可靠吗？
一个python多 生产环境 者和多消费者线程伪代码： def threadProducer(): while upstreams_not_done: data = do_some_work() queue_of_data.put(data) def threadConsumer(): while True: data = queu... -
8 votesanswersviews
Radix使用队列排序
我想用队列创建一个radix sort实现 . 我无法弄清楚我的代码的哪个部分有问题或我应该阅读哪些资源 . 我的代码可能完全错误，但这是我的实现没有任何帮助（我尚未采用数据结构和算法课程） . 我创建了一个函数，但它没有用 . 在做研究时，我看到了一些代码示例，但对我来说似乎更复杂 . Firstly 我想找到所有整数的最低有效位 Then 将它们排序在其下标匹配的队列元素中， then 将排序... -
3 votesanswersviews
在ExecutorService的newFixedThreadPool（）中处理队列？
根据this explanation given in Javadocs，它说下面的内容 public static ExecutorService newFixedThreadPool(int nThreads) 创建一个线程池，该线程池重用在共享的无界队列中运行的固定数量的线程 . 在任何时候，最多nThreads线程将是活动的处理任务 . 如果在所有线程都处于活动状态时提交了其他任务，则它... -
2 votesanswersviews
批量迭代如何在Tensorflow中工作？
我试图在我的数据上重用PTB language model但是缺乏Tensorflow的知识来理解它如何处理训练数据的批量迭代 . 以下是我在培训期间理解批量迭代的方法： while epoch <= maxepoch do for minibatch in data_iterator() do model.forward(minibatch) (...) end e... -
0 votesanswersviews
RabbitMQ稍后会确认消息
为了避免在队列读取器进程崩溃的情况下数据丢失，我们需要从RabbitMQ获取未确认的消息 . 对于每1000条消息，我们将消息数据提交到磁盘，然后可以将这些消息标记为已确认和已消耗 . 有没有办法让他们不被承认，然后专门针对那些我们刚刚得到的？例如，我们可以将它们添加到列表中，然后遍历该列表以查找消息吗？这是在RabbitMQ .net FYI . -
10 votesanswersviews
RabbitMQ是否能够将消息从队列“推送”到消费者身上？
使用RabbitMQ，是否有一种方法可以将消息从队列“推送”到消费者，而不是让消费者从队列中“轮询和拉取”消息？ 这一直是我正在进行的当前项目辩论的原因 . 一方面的论点是，让消费者（即Windows服务）“轮询”队列直到新消息到达，这比将消息从队列“自动”推送到订户的想法有些低效且不太理想 . /消费者（一个或多个） . 我似乎只能找到支持消费者从队列中“轮询和拉动”消息的想法的信息（例如，使... -
1 votesanswersviews
如何使用注释在Spring AMQP中将队列/消息持久性设置为false？
我编写了示例spring amqp producer，它运行在RabbitMQ服务器上，该服务器使用Spring AMQP发送消息并使用MessageListener消费这些消息 . 在这里，我想将队列和消息持久性设置为false . 你能不能请任何人帮助我如何使用注释将“持久”标志设置为false . 这是示例代码 @Configuration public class ProducerCon... -
0 votesanswersviews
如何重新传递RabbitMQ已经发送给消费者的消息
我创建了一些连接到Rabbitmq中的队列的消费者，每次都需要10,50,100个消息，以避免不必要的连接 . 有时我们遇到队列几乎为空的情况，只有一个消费者获得了所有消息 . 不幸的是，其中一条消息可能处理缓慢（例如第三方Web服务超时），而其他所有消息都必须排队等待，即使它们更快 . 虽然这样，其他消费者都是空的，无所事事，但他们无法接收第一个仍未处理的消息 . 如果我可以向Rabbitmq发... -
1 votesanswersviews
当RabbitMQ消费者崩溃时，获取的消息会发生什么？
如果我有一个RabbitMQ使用者可以批量检索100条消息，但是在它将这些消息标记为已处理之前它会崩溃，这些消息会丢失吗？我希望队列中的每条消息至少处理一次 . 在确认消息之前，建议的方法是如何处理崩溃的消费者？ RabbitMQ是否会以某种方式将它们放回队列中，或者我需要做些什么来实现它？ -
2 votesanswersviews
使用MySQL作为作业队列
我想将MySQL用作作业队列 . 多台机器将 生产环境 和消耗工作 . 工作需要安排;有些可能每小时运行一些，每天运行一些，等等 . 这似乎相当简单：对于每个作业，都有一个“nextFireTime”列，并让工作机器使用nextFireTime搜索作业，将记录的状态更改为“inProcess”，然后在作业结束时更新nextFireTime . 当一个 Worker 无声地死去时，问题就出现了 . ... -
17 votesanswersviews
Java BlockingQueue与批处理？
我对与Java BlockingQueue相同的数据结构感兴趣，但它必须能够批处理队列中的对象 . 换句话说，我希望 生产环境 者能够将对象放入队列，但是在 take() 上使用消费者块，直到队列达到一定的大小（批量大小） . 然后，一旦队列达到批量大小， 生产环境 者必须阻止 put() 直到消费者已经消耗了队列中的所有元素（在这种情况下， 生产环境 者将再次开始 生产环境 并且消费者块直到再次... -
3 votesanswersviews
加入多处理队列需要很长时间
在Python 2.7中，我实现了一个包含多个队列和消费者的多处理场景 . 简化的想法是，我有一个作业 生产环境 者，它被提供给消费者，处理作业和一个错误处理程序，它完成所有日志记录 . 非常简化，它看起来都与之相当： import multiprocessing as mp import Queue job_queue = mp.Queue() error_queue = mp.Queue()... -
0 votesanswersviews
实现队列队列的队列代理
我正在寻找使用队列代理来处理我的用例，但我找不到适合我需求的代理 . 也许我的需求并不常见，或者我正在解决我的问题 . 情况：数百万人的人口统计数据信息进入系统 . 这些消息中的每一个都具有该人唯一的标识符 . 不幸的是，发送系统差异很大，有些人的奇怪做法导致同一个人在很短的时间内进入系统的数十个，甚至偶尔有数百个 . 我们当前的排队系统有多个处理器，不知道这些人及其标识符，它基本上是一个基于时间... -
2 votesanswersviews
Python有过滤队列吗？
我有一种情况，我有一个 生产环境 者线程从网络上的各种不同设备接收消息 . 我还有多个消费者线程，只想从特定设备接收数据 . 我通常做的是让消费者线程自己“注册” 生产环境 者线程并创建他们自己的单独队列， 生产环境 者线程将相关数据插入其中 . 但是，我想要的是拥有 生产环境 者将消息放入的单个队列对象，然后让消费者从队列中“获取”数据但是使用过滤器，以便他们只接收他们感兴趣的消息 . Pyth... -
32 votesanswersviews
作业队列为具有多个使用者的SQL表（PostgreSQL）
我有一个典型的 生产环境 者 - 消费者问题： 多个 生产环境 者应用程序将作业请求写入PostgreSQL数据库上的作业表 . 作业请求的状态字段在创建时包含QUEUED . 当 生产环境 者插入新记录时，规则会通知 multiple 个消费者应用程序： CREATE OR REPLACE RULE "jobrecord.added" AS ON INSERT TO jo... -
2 votesanswersviews
推荐使用TPL用于非常长的生命线程
我已经阅读了一些关于任务并行库（http://msdn.microsoft.com/en-us/library/dd537609(v=vs.110).aspx）的MSDN文档，特别是关于TPL的最佳实践用法 . 我有一个启动线程的应用程序 . 该线程的目的是监视队列并“处理”已添加的项目 . 队列中项目的处理需要按顺序进行，因此我不希望从队列中一次处理多个项目 . 只要windows进程，该线程就... -
-2 votesanswersviews
Azure WebJob QueueTrigger抛出StorageException 404 Not Found
我正在使用Azure Queues，使用WebJob控制它们，在函数文件中我有一个QueueTrigger函数，当AzureQueue收到一些消息时它会激活 . 现在的问题是函数（QueueTrigger）成功执行，我在队列触发器函数中设置了正确的异常处理，所有操作都没有任何错误地执行 . 但是当QueueTrigger函数结束时，代码抛出异常 . 存储异常404未找到 . 并且该消息未从队列中删... -
0 votesanswersviews
Azure功能：无法加载文件或程序集WebJobs.Host
我说错了 错误：函数运行时无法启动 . mscorlib：无法加载文件或程序集“Microsoft.Azure.WebJobs.Host，Version = 3.0.0.0，Culture = neutral，PublicKeyToken = null”或其依赖项之一 . 该系统找不到指定的文件 . 我是否需要在天蓝色门户中设置任何内容？我可以在我的本地机器上运行它 . 在我将函数发布到az... -
0 votesanswersviews
ActiveMq无法访问队列网页
我英文不太好 . 但是当我访问activemq队列页面时遇到问题 . 当我访问http://MY-IP:8161/admin/queues.jsp并且网页返回我时：错误！ 处理此请求时发生异常，请检查日志以获取更多信息！ 在我查看日志后端之后，它显示： 2017-11-02 08:26:05,892 | WARN | | org.eclipse.jetty.servlet.ServletHan... -
0 votesanswersviews
无法在ActiveMQ代理中创建队列
在其中一个ActiveMQ实例（v5.13.3）中，当尝试使用Web控制台手动创建队列时，收到错误，如下所示 在ActiveMQ日志中，没有错误，但警告如下 . 此实例适用于现有队列和主题 . 只在尝试新队列时遇到问题 . 即使重启也没有帮助 . 使用类似的设置，它在另一个实例中工作正常 . 2018-07-05 14:42:49,700 | WARN | /admin/createDestin...