可调用和泛型的集合

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

这是我的代码：

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> with <Object>，并让我的所有任务返回Object（例如替换SomeTask1 implements Callable<Double> with SomeTask1 implements Callable<Object>).

但我的问题是：为什么会出现这个错误？我不明白为什么我不能这样编码。谁能说清楚吗？

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

这说明有一个类型变量T使得论证是Collection<? extends Callable<T>>。也就是说，此方法签名假定列表中的所有 Callable 都具有相同的类型参数。您的列表并非如此，这就是编译器拒绝您的代码的原因。

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();
}

如果您多次需要它，您可以将其放入实用方法中，请记住使用正确的签名;-)