在ThreadPoolExecutor文档上,它说要使用Executors类来创建公共线程,我只想拥有一个线程,所以我使用Executors.newSingleThreadExecutor并像我看到的其他示例那样将它转换为ThreadPoolExecutor,但是这会抛出一个java.lang.ClassCastException。import java.util.concurrent.Executors;
public cl
我们面临的问题是,当消息在队列中时,如何处理系统崩溃,不知何故,每次作业唤醒时,我们都需要查看我们的数据库,以找出是否有任何未在队列中的原始消息。最简单的方法是查询当前队列大小,并确定队列中的原始msg是否比msg多。所以我的问题是: ExecutorChannel有没有什么API可以找出队列的大小?或者其他的建议?
Thx Jason