我在代码中使用 Executors.newSingleThreadExecutor()。 我想监视队列中的任务数,以检查处理器是否没有因消息而重载。如何获得当前未完成的提交任务数? 我期待这样的事情:
ExecutorService executor = Executors.newSingleThreadExecutor();
executor.submit(new Runnable() {...});
executor.submit(new Runnable() {...});
executor.submit(new Runnable() {...});
// do something and get 3
...
// do something and get 2
...
// do something and get 1
谢谢
最佳答案
以防万一你想保证即使使用新版本的 JVM,FlorianOver 建议的代码也能工作,你可以这样做:(对于方法 Executors.newSingleThreadExecutor() 将不再返回一个ThreadPoolExecutor 类型的实例)
ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
// ...
int queueSize = executor.getQueue().size();
关于java - Executors.newSingleThreadExecutor() - 如何查看队列中有多少任务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5883373/