java - PriorityExecutor 和 ExecutorCompletionService 可以吗？

Question

我已经实现了一个基于的 PriorityExecutor http://funofprograming.blogspot.co.il/2013/11/priorityexecutorservice-for-java.html和 Specify task order execution in Java

但是我想使用 ExecutorCompletionService 并将其交给 PriorityExecutor

但是我得到以下执行:

Caused by: java.lang.ClassCastException: java.util.concurrent.ExecutorCompletionService$QueueingFuture cannot be cast to java.lang.Comparable
    at java.util.concurrent.PriorityBlockingQueue.siftUpComparable(PriorityBlockingQueue.java:347)
    at java.util.concurrent.PriorityBlockingQueue.offer(PriorityBlockingQueue.java:479)
    at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1364)
    at java.util.concurrent.ExecutorCompletionService.submit(ExecutorCompletionService.java:188)
    at com.ibm.modmt.impl.sommosAlg.meta.PoolStrategy.multiSubmit(PoolStrategy.java:160)
    at com.ibm.modmt.impl.sommosAlg.meta.MultiSOMMOSTask.multiSubmit(MultiSOMMOSTask.java:157)
    at com.ibm.modmt.impl.sommosAlg.meta.MultiSOMMOSTask.call(MultiSOMMOSTask.java:85)
    at com.ibm.modmt.impl.sommosAlg.meta.MultiSOMMOSTask.call(MultiSOMMOSTask.java:1)
    at java.util.concurrent.FutureTask.run(FutureTask.java:262)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    ... 1 more

完成服务似乎从我的 Comaprable Future 创建了自己的 Future(QueueFuture)。

有人用 ExecutorCompletionService 实现了 PriorityExecutor 吗？我是否需要扩展 ExecutorCompletionService 如果需要的话如何？

Answer 1

我没有看到任何方法可以使用内置实现来做到这一点。然而，ExecutorCompletionService 是相当简单的代码，并且是 GPL，因此您可以复制它供您自己使用并修改它以处理您的自定义 Future。