Akka / futures - Akka 是否决定使用当前线程或调度程序是否“值得”？

Question

我目前正在考虑使用 Akka（Java API/库）来完成创建多个 Futures 并将它们放入 BlockingQueue 的任务。现在可能是由 Callables 处理的某些任务在调用线程中运行得更快/更快，而不是创建新线程或等待新线程可用。我认为 Akka 正是这样做的，例如，如果我正在跑步：

Future<String> f1 = future(new Callable<String>() {
                  public String call() {
                      return "Hello" + "World";
                  }
              });

它可能在调用future(Callable)的当前线程中执行还是我错了？也许我错了，因为我不明白调度程序将如何决定是否创建新线程。

现在我只是使用一个使用其他线程的 ExecutorService，但由于某些任务真的非常快，它们也可以由当前线程处理。但我使用的是BlockingQueue<Future<Float>>，这就是为什么我有时不能使用Futures，有时不能。

最好的问候，
约翰内斯

Answer 1

它总是使用提供的调度程序中的一个线程，或者如果没有指定，则使用全局默认值。要使用同一个线程，您需要传入一个 CallingThreadDispatcher，但它始终是同步的。除了程序员之外，根本没有任何人可以决定计算是否便宜。