Akka/future - Akkaは、現在のスレッドまたはディスパッチャを使用して "価値がある"かどうかを判断しますか？

Question

私は現在、いくつかのFutureを作成してBlockingQueueに入れるというタスクを達成するためにAkka（Java API /ライブラリ）を使用することを考えています。今度は、新しいスレッドを作成するか、新しいスレッドが利用可能になるのを待つのではなく、Callableによって処理されるいくつかのタスクが、呼び出しスレッドで高速/高速で実行されることがあります。

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

をそれは未来を呼び出し、現在のスレッド（コーラブル）で実行される可能性がありますか私は間違っている：私は実行している場合、私は、たとえば、アッカは、まさにこれをやっていると思いますか？新しいスレッドが作成されたかどうかをディスパッチャがどのように判断するのか分からないので、私は間違っているかもしれません。

今は他のスレッドを使用するExecutorServiceを使用していますが、実際には実際のスレッドで処理できるタスクもあるため、現在のスレッドで処理できる可能性があります。しかし私はBlockingQueue<Future<Float>>を使用しているので、時にはFutureを使用できないことがあります。

よろしく、
ヨハネス

Answer 1

誰が指定されていない場合、それは常に供給ディスパッチャ、またはグローバルなデフォルトから糸を使用しています。同じスレッドを使用するには、CallingThreadDispatcherを渡す必要がありますが、常に同期します。プログラマを除いて誰かが計算が安いかどうかを決める方法は全くありません。