嗨，
目前我正在开发一个程序，该程序从 amq 队列中获取 2 个值并对它们执行一系列数学计算。我的程序订阅并通过回调（侦听器）接收消息的 amq 服务器上创建了一个主题。
现在，每当消息到达时，这两个值就会被取出并添加到 SynchronizedDescriptiveStatistics 对象中。在每次添加到值列表之后，整个计算序列都会重新执行（这实际上是要求的一部分）。
我现在面临的问题是，由于我使用的是侦听器，因此有时在计算过程中会收到一条或多条消息。尽管 SynchronizedDescriptiveStatistics 自己处理所有与线程相关的问题，但是当它失锁或其他情况时，它会立即将所有等待值添加到其数字列表中。虽然我的问题是添加一个值，然后对其执行 calcls，然后是第二个值，然后不断地执行。
我想出的解决方案是在我的程序中使用作业队列（不是 amq 队列）。这样，每当计算结束时，程序就会在队列中寻找更多的作业并相应地继续。
由于我也在寻找效率和速度，我认为 Disruptor 框架可能对这个问题有好处，并且它针对线程情况进行了优化。但我不确定在我的应用程序中实现 Disruptor 是否值得，因为常规的标准队列可能足以满足我想要做的事情。
让我还告诉您，需要执行计算的数据很多，并且会不断出现，并且每次添加单个值时都需要以连续方式重新执行整个计算。因此，请牢记效率和海量数据，您认为从长远来看什么是有用的。
等待答复。. .
问候。