この記事では、Java マルチスレッドにおける Callable と Future についての詳細な紹介 (コード例) を紹介します。必要な方は参考にしていただければ幸いです。
Callable と Future が登場する理由
スレッドを作成するには 2 つの方法があります。1 つは Thread を直接継承する方法、もう 1 つは Runnable インターフェースを実装する方法です。 。
これら 2 つの方法には欠点があります。タスクの完了後に実行結果を取得できないということです。
実行結果を取得する必要がある場合は、共有変数またはスレッド通信を通じて結果を取得する必要があり、使用するのがより面倒です。
Java 1.5からは、タスクの実行完了後にタスクの実行結果を取得できるCallableとFutureが提供されています。
Callable と Future の概要
Callable インターフェイスは、呼び出して結果を返すことができるコードの一部を表し、Future インターフェイスは非同期タスクを表します。まだ終わっていない仕事がもたらす未来。したがって、Callable は結果の生成に使用され、Future は結果の取得に使用されます。
Callable インターフェイスはジェネリックスを使用して戻り値の型を定義します。 Executors クラスは、スレッド プール内の Callable 内でタスクを実行するための便利なメソッドをいくつか提供します。 Callable タスクは並列であるため (並列とは、全体が並列に見えることを意味します。実際には、特定の時点で 1 つのスレッドだけが実行されます)、返される結果を待つ必要があります。
java.util.concurrent.Future オブジェクトは、この問題を解決します。スレッド プールが Callable タスクを送信すると、Future オブジェクトが返され、これを使用して Callable タスクのステータスを確認し、Callable によって返された実行結果を取得できます。 Future は、Callable が終了するのを待ってその実行結果を取得できるように get() メソッドを提供します。
呼び出し可能および実行可能
java.lang.Runnable、これはインターフェイスであり、その中で宣言されている run() メソッドは 1 つだけです:
public interface Runnable { public abstract void run(); }
run()メソッドの戻り値はvoid型のため、タスク実行後に結果は返されません。
Callable は java.util.concurrent パッケージの下にあり、これもインターフェイスであり、その中で宣言されているメソッドは 1 つだけですが、このメソッドは call() と呼ばれます:
public interface Callable<V> { /** * Computes a result, or throws an exception if unable to do so. * * @return computed result * @throws Exception if unable to compute a result */ V call() throws Exception; }
Thisジェネリック インターフェイスの場合、call() 関数によって返される型は、渡された V 型です。
通常、これは ExecutorService と組み合わせて使用され、submit メソッドのいくつかのオーバーロードされたバージョンが ExecutorService インターフェイスで宣言されます。
<T> Future<T> submit(Callable<T> task); <T> Future<T> submit(Runnable task, T result); Future<?> submit(Runnable task);
最初の submit メソッドのパラメーターの型は Callable です。
現時点では、Callable は一般的に ExecutorService と組み合わせて使用されることだけを知っておいてください。具体的な使用方法については後述します。
通常、最初の送信メソッドと 3 番目の送信メソッドが使用され、2 番目の送信メソッドはほとんど使用されません。
Future は、特定の Runnable または Callable タスクの実行結果をキャンセルし、完了したかどうかをクエリし、結果を取得することです。必要に応じて、タスクが結果を返すまでブロックされる get メソッドを通じて実行結果を取得できます。
Future クラスは java.util.concurrent パッケージの下にあります。これは、Future インターフェースで 5 つのメソッドを宣言します。
public interface Future<V> { boolean cancel(boolean mayInterruptIfRunning); boolean isCancelled(); boolean isDone(); V get() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; }
public FutureTask(Callable<V> callable) { if (callable == null) throw new NullPointerException(); sync = new Sync(callable); } public FutureTask(Runnable runnable, V result) { sync = new Sync(Executors.callable(runnable, result)); }
如上提供了两个构造函数,一个以Callable为参数,另外一个以Runnable为参数。这些类之间的关联对于任务建模的办法非常灵活,允许你基于FutureTask的Runnable特性(因为它实现了Runnable接口),把任务写成Callable,然后封装进一个由执行者调度并在必要时可以取消的FutureTask。
FutureTask可以由执行者调度,这一点很关键。它对外提供的方法基本上就是Future和Runnable接口的组合:get()、cancel、isDone()、isCancelled()和run(),而run()方法通常都是由执行者调用,我们基本上不需要直接调用它。
public class MyCallable implements Callable<String> { private long waitTime; public MyCallable(int timeInMillis){ this.waitTime=timeInMillis; } @Override public String call() throws Exception { Thread.sleep(waitTime); //return the thread name executing this callable task return Thread.currentThread().getName(); } }
public class FutureTaskExample { public static void main(String[] args) { MyCallable callable1 = new MyCallable(1000); // 要执行的任务 MyCallable callable2 = new MyCallable(2000); FutureTask<String> futureTask1 = new FutureTask<String>(callable1);// 将Callable写的任务封装到一个由执行者调度的FutureTask对象 FutureTask<String> futureTask2 = new FutureTask<String>(callable2); ExecutorService executor = Executors.newFixedThreadPool(2); // 创建线程池并返回ExecutorService实例 executor.execute(futureTask1); // 执行任务 executor.execute(futureTask2); while (true) { try { if(futureTask1.isDone() && futureTask2.isDone()){// 两个任务都完成 System.out.println("Done"); executor.shutdown(); // 关闭线程池和服务 return; } if(!futureTask1.isDone()){ // 任务1没有完成,会等待,直到任务完成 System.out.println("FutureTask1 output="+futureTask1.get()); } System.out.println("Waiting for FutureTask2 to complete"); String s = futureTask2.get(200L, TimeUnit.MILLISECONDS); if(s !=null){ System.out.println("FutureTask2 output="+s); } } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); }catch(TimeoutException e){ //do nothing } } } }
以上がJava マルチスレッドでの Callable と Future の詳細な紹介 (コード例)の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。