可调用和泛型的集合

Question

我需要在并发线程中启动一堆任务并检索其结果.

这是我的代码:

List<Callable<? extends Object>> tasks = new ArrayList<>();

// Adding some tasks whith return different types of results:
// Callable<Double>, Callable<String>, Callable<SomeOtherType>, and so on...

List<Future<? extends Object>> results = executor.invokeAll( tasks );

但IDE显示下一个错误:

no suitable method found for invokeAll(List<Callable<? extends Object>>)

    method ExecutorService.<T#1>invokeAll(Collection<? extends Callable<T#1>>)
            is not applicable
      (cannot infer type-variable(s) T#1
        (argument mismatch; List<Callable<? extends Object>> cannot be converted
                to Collection<? extends Callable<T#1>>

    method ExecutorService.<T#2>invokeAll(Collection<? extends Callable<T#2>>,long,TimeUnit)
            is not applicable
      (cannot infer type-variable(s) T#2
        (actual and formal argument lists differ in length))

  where T#1,T#2 are type-variables:
    T#1 extends Object declared in method
            <T#1>invokeAll(Collection<? extends Callable<T#1>>)
    T#2 extends Object declared in method
            <T#2>invokeAll(Collection<? extends Callable<T#2>>,long,TimeUnit)

方法签名是:

<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)

很显然,我可以代替<? extends Object>使用<Object>,使我的所有任务返回Object(如更换SomeTask1 implements Callable<Double>用SomeTask1 implements Callable<Object>).

但我的问题是:为什么会出现这种错误？我不明白为什么我不能这样编码.任何人都可以说清楚吗？

Answer 1

<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)

这表示有一个类型变量T,参数是a Collection<? extends Callable<T>>.也就是说,此方法签名假定列表中的所有Callables都具有相同的类型参数.您的列表不是这种情况,这就是编译器拒绝您的代码的原因.

api方法应该声明如下:

<T> List<Future<? extends T>> invokeAll(Collection<? extends Callable<? extends T>> tasks);

在Java中设计通用API时,这是众所周知的陷阱.缺少声明站点协方差(允许一个人声明Callable<String>是子类型Callable<Object>)需要在泛型类型的每次使用时指定与通配符类型的协方差.也就是说,API永远不应该写Callable<T>,但总是如此Callable<? extends T>.当然,正如这个例子所示,这是多余的,容易忘记.

在您的特定情况下,最好这样做:

List<Future<?>> futures = new ArrayList<>();
for (Callable<?> callable : tasks) {
     futures.add(executor.submit(callable));
}
for (Future<?> future : futures) {
    future.get();
}

如果你不止一次需要这个,你可以把它放到一个实用工具方法中,记住要使用正确的签名;-)