Java TimerTask 应该等待阻塞队列

Question

我有以下设计:

有一个任务扩展了TimerTask，并且计划每分钟运行一次。此任务将尝试从中央队列(作为单个消费者)获取项目并将其表示形式写入文件中。

此外，还有多个生产者不时将项目放入中央队列。

我感兴趣的是，每次执行任务(执行 run() 方法)时，如果有项目，它将从队列中提取所有项目，如果有没有任何项目不执行任何操作。

如果队列已满，生产者应该在队列上 hibernate 。

我对这个问题的解决方案是:

创建扩展 TimerTask 的 ExtractTask。ExtractTask 将包含一个 BlockingQueue。每个生产者将通过执行 getQueue() 方法接收对队列实例的引用。生产者将执行 BlockingQueue.put() 方法。消费者将在 run() 中执行 BlockingQueue.poll() 方法。

你能提出更好的设计吗？我的设计是否包含任何有问题的场景案例？此设计可能会遇到任何同步问题吗？

Answer 1

我愿意:

• 将队列与设计中的任务分开，
• 注入(inject)队列而不是进行查找，
• 使用 SchedulerService 而不是 TimerTask

除此之外，你已经得到了它。

如果您愿意冒依赖 Spring 的风险，您应该查看 Spring Integration 。您描述的所有组件都在那里。您还可以使用许多其他框架来解决问题，例如 Camel 或 Akka；我的主要观点是，如果不是绝对必要的话，不要自己维护此代码。

免责声明:我有点biased about Spring Integration