摘要：相對于，并不是很讓人熟知，其實和很類似，只不過它有返回值，并且也沒有方法，而是有方法。接口類似于，兩者都是為那些其實例可能被另一個線程執(zhí)行的類設(shè)計的。但是不會返回結(jié)果，并且無法拋出經(jīng)過檢查的異常。
Callable
相對于Runnable，Callable并不是很讓人熟知，其實Callable和Runnable很類似，只不過它有返回值，并且也沒有run()方法，而是有call()方法。
public interface Callable{
V call() throw Exception;
}
Callable 接口類似于 Runnable，兩者都是為那些其實例可能被另一個線程執(zhí)行的類設(shè)計的。但是 Runnable 不會返回結(jié)果，并且無法拋出經(jīng)過檢查的異常。
可以看到，返回的結(jié)果是以V泛型表示的，比如Callable表示一個最終返回Integer的異步計算
Future
Future用來保存異步計算的結(jié)果，就是說之前用Callable標(biāo)志的任務(wù)可以用Future來進(jìn)行包裝，那為什么非要用Future呢，Callable自己運行然后用相應(yīng)的類型來接收結(jié)果不就行了嗎？之所以要用到Future，有一下兩個原因：
Thread t = new Thread(..)用這個方法創(chuàng)建一個線程，必須要傳給一個Runnable的參數(shù)，而不能傳給它Callable
Future對象具有一系列的方法，比如它的get方法能夠被阻塞，直到計算完成；也可以在任務(wù)進(jìn)行的過程中取消它。這些方法使得它更便利
FutureTask
但是Future終究只是一個接口，而FutureTask包裝器不僅實現(xiàn)了Future接口，還實現(xiàn)了Runnable接口，這彌補上面的遺憾，使得它不僅能被Thread運行，還具有取消運行的特性，一個典型的使用FutureTask的例子就是：
Callable calc = ...;
FutureTask task = new FutureTask(calc);
Thread t = new Thread(task); //這里是Runnable
t.start;
...
Integer result = task.get(); //這里是Future
住：FutureTask的兩個構(gòu)造方法
FutureTask(Callable task)
FutureTask(Runnable task,V result)
Demo
一個計算指定目錄下具有指定關(guān)鍵字的文件數(shù)目的例子：
package future;
import java.io.File;
import java.io.FileNotFoundException;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.FutureTask;
public class MatchCounter implements Callable {
private File directory;
private String keyword;
private int count;
public MatchCounter(File directory, String keyword) {
this.directory = directory;
this.keyword = keyword;
}
@Override
public Integer call() throws Exception {
count = 0;
try {
File[] files = directory.listFiles();
List> results = new ArrayList<>(); // 用來保存所有的異步計算結(jié)果
for (File file : files) {
if (file.isDirectory()) {
MatchCounter counter = new MatchCounter(file, keyword);
FutureTask task = new FutureTask<>(counter);
results.add(task);
Thread t = new Thread(task);
t.start();
} else {
if (search(file)) {
count++;
}
}
}
for (Future r : results) {
count += r.get();
}
} catch (InterruptedException e) {
}
return count;
}
public boolean search(File file) {
try {
Scanner in = new Scanner(file);
boolean found = false;
while (in.hasNextLine()) {
String line = in.nextLine();
if (line.contains(keyword)) {
found = true;
}
}
return found;
} catch (FileNotFoundException e) {
e.printStackTrace();
}
return false;
}
}
測試類：
package future;
import java.io.File;
import java.util.Scanner;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
public class FutureTest {
public static void main(String[] args) {
Scanner in = new Scanner(System.in);
System.out.println("Enter starting directory:");
String d = in.nextLine();
System.out.println("Enter keyword:");
String keyword = in.nextLine();
MatchCounter counter = new MatchCounter(new File(d), keyword);
FutureTask task = new FutureTask<>(counter);
new Thread(task).start();
try {
System.out.println(task.get() + " matching files!");
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
運行：
Enter starting directory:
D:workspaceconcurrentsrc
Enter keyword:
future
2 matching files!
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://specialneedsforspecialkids.com/yun/64439.html
