确定ExecutorService中当前正在运行的可调用项

Question

我希望能够获得我已经提交给执行服务（特别是线程池执行器）的Callable（因此它们不能通过getQueue（））。

我试图创建一个子类来覆盖beForeExecute之前的，但是给定的Runnable结果是一个FutureWork，而不是提交的原始Callable。

是否有其他方法来确定活动可调用项？

最后，我想用这些信息做两件事：

1. 获取正在运行的任务，以便在用户界面中显示它们
2. 检查Callable引用的文件是否匹配模式，如果匹配，则取消它




Answer 1

正如axtavt所建议的，我创建了一个FutureWG的子类：

public class FutureCallable<V> extends FutureTask<V> {
    private Callable<V> callable;

    public FutureCallable(Callable<V> callable) {
        super(callable);
        this.callable = callable;
    }

    public Callable<V> getCallable() {
        return callable;
    }

}

并重写myThreadPoolExecutor子类中的一些方法：

public class CustomThreadPoolExecutor extends ThreadPoolExecutor {
    private Set<FutureCallable<UpdateResult>> running = new HashSet<FutureCallable<UpdateResult>>();

    @Override
    public <T> FutureCallable<T> newTaskFor(Callable<T> callable) {
        return new FutureCallable<T>(callable);
    }

    @Override
    protected void beforeExecute(Thread t, Runnable r) {
        FutureCallable<UpdateResult> task = (FutureCallable<UpdateResult>) r;
        running.add(task);
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        FutureCallable<UpdateResult> task = (FutureCallable<UpdateResult>) r;
        running.remove(task);
    }

    ...
}

Answer 2

匿名用户

您可以重写AbstractExecutorService.newTaskFor（），它应该允许您访问原始的Runnables和Callables。然后用跟踪装饰器装饰它们，并传递到super.newTaskFor（）。