问如何保存ThreadPoolExecutor的队列，以便在重启后可以恢复？
EN

Stack Overflow用户

提问于 2015-12-24 08:58:43

回答 1查看 86关注 0票数 0

我正在尝试开发一个使用Spark ( web框架)的应用程序，我需要在后台处理一些东西(异步)，这样我就不会阻塞用户。

为此，我正在考虑使用ThreadPoolExecutor。有没有一种方法可以保存队列，稍后恢复？(可能应用程序被停止/重新启动，而队列中仍有项目)。

另外，您如何向用户报告进度(挂起、进行中、完成)？

基本上，我正在寻找的是类似于Celery的东西，但对于Java，它需要嵌入到我的应用程序中，这样用户就不需要安装额外的服务。

发布于 2015-12-24 09:15:20

ThreadPoolExecutor类提供了一个名为getQueue()的方法来公开队列。

然后，当您在关闭旧的executor之后创建新的executor时，您应该能够重用queue对象(及其内容)。

另一种可能是通过使用自定义队列类来实现executor挂起/恢复，您可以在外部阻塞和解除阻塞。这样做的好处是，当您挂起和恢复执行程序时，不需要销毁/重新创建池线程。

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/34445925

复制

相似问题

问如何保存ThreadPoolExecutor的队列，以便在重启后可以恢复？EN