跟踪提交给ThreadPoolExecutor的任务

Question

我正在ThreadPoolExecutor中运行多个任务。我将其初始化如下：

private VideoExportExecutor executor;
private BlockingQueue<Runnable> jobQueue;

public void initialiseVideoProcessor()
{
    jobQueue = new LinkedBlockingQueue<Runnable>();
    executor = new VideoExportExecutor(1, 1, Long.MAX_VALUE, TimeUnit.SECONDS, jobQueue);
}

我自己实现了runnable（VideoExportThread），其中包含一个getgres（）方法来跟踪提交任务的进度。我提交的实例如下：

executor.submit(new VideoExportThread(gcmPath));

我正在寻找一种查询当前/挂起线程的执行器/阻塞队列的方法。我尝试使用jobQueue。toArray（）和重写executor方法beforeExecute（线程t，Runnable r）但在这两种情况下，返回的Runnable都是FutureTask类型，不包含太多数据。有没有一种方法可以让我使用它来检索原始的VideoExportThread实例，以便识别哪些实例正在运行并查询其进度？

谢啦

Answer 1

为什么不简单地列出你的跑步记录呢？

List<Runnable> runnables = new ArrayList<> ();
VideoExportThread r = new VideoExportThread(gcmPath);
runnables.add(r);
executor.submit(r);

另请注意，executor.submit（r）；返回一个Future-您可以调用它的isDone（）方法来检查提交的任务是否仍在运行。

旁注：手动管理作业队列可能是一个很好的理由，但如果不是，您可以使用工厂方法之一来简化您的生活。例如：<代码>ExecutorService executor=执行者。newCachedThreadPool（） 。