我正在寻找 BoundedBlockingQueue 可以带任何其他 Queue 并使其有限和阻塞。

我发现 akka.util.BoundedBlockingQueue 可以做到这一点,但是源代码中有一些修复程序。因此,我不确定使用代码是否聪明。

最后,我希望有一个优先级的限制,并且可以同时使用。

我还可以使用其他一些课程来完成此任务吗?也许在Java 7中?

有帮助吗?

解决方案

Akka Boundedblockingquequequequeque似乎对我来说还不错(源代码)。我真的会考虑使用它(至少在为课程编写了一组好的单元测试之后,因为AKKA中缺少该课程的测试)

fixmes处于非常奇怪的情况,例如在备用队列上呼叫removeAll,之后它不是空的,这只是备用队列类实现时的一个非常严重的错误。

我不明白你的意思 “代码不允许我使构造函数通用”.

许可以下: CC-BY-SA归因
不隶属于 StackOverflow
scroll top