java多线程轮流

Question

我有 2 个 java 线程接收 UDP 多播。

每个线程将接收来自不同多播流的 UDP 数据包，例如大约 60 Mbps，然后处理共享 BlockingQueue 中的 UDP 数据包和队列。 UDP 数据包大约 1300 字节。

我想要队列中处理的 UDP 数据包的顺序，这与数据包到达机器 NIC 的方式相同，即使从不同线程（不同的多播流）接收数据包也是如此。

我无法在这些线程中实现这一点，这是我的问题。

是否可以使用 java，或者我应该使用 C 之类的其他语言？

编辑

基本上，线程将从不同的多播流接收多播，队列中的数据包顺序将取决于接收线程如何执行以从 NIC 获取数据包的顺序，但我希望顺序与数据包到达 NIC 的方式相同。

我尝试降低每个流的 UDP 接收缓冲区，数据包几乎按顺序进入队列，但数据包开始丢失。如果我增加接收缓冲区，队列中的顺序完全取决于接收线程的执行方式。

请帮助我。有可能吗？

Answer 1

序列号？定义一个流控制类，该类包含一个序列号，该序列号递增并加载到从该流接收的每个缓冲区对象中，池线程可以检查的“最后处理”号以及每个乱序缓冲区的列表已被您的池出列。

池线程检查它们出列的缓冲区是否具有正确的序列号（last-processed+1）。如果是这样，它们会处理该缓冲区以及列出的缓冲区中的任何后续数字。如果没有，他们将该缓冲区添加到列表中以供以后处理。

PS：流控制类方法肯定需要锁定。