1. FutureTask的类图
public Thread(Runnable target)
public FutureTask(Callable
public FutureTask(Runnable runnable, V result)
Thread 代表的是线程,用来执行任务。
Runable代表的是一个任务。
Callable也代表的是一个任务。
Future 代表的是结果(简单可以这样理解)。
2. Future
package java.util.concurrent;
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;
}
3. FutureTask使用Demo
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
public class FutureTaskDemo {
public static void main(String[] args) {
ACallAble aCallAble = new ACallAble();
FutureTask futureTask = new FutureTask(aCallAble);
Thread thread = new Thread(futureTask);
thread.start();
do {
} while (!futureTask.isDone());
//Future更多的暗示你可以在等待这个结果的同时可以使用其他的线程做一些其他的事情
new Thread(() -> {
try {
TimeUnit.SECONDS.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
}, "其他线程").start();
try {
//获取结果,这里会阻塞等待futureTask执行完成返回结果
//在这个等待的过程可以让其他线程去执行任务
Object result = futureTask.get();
System.out.println("Result:" + result);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
class ACallAble implements Callable {
@Override
public Object call() throws Exception {
Thread.sleep(1000);
return "Thread-Name:" + Thread.currentThread().getName();
}
}
可以看到,使用FutureTask来启动一个线程之后,我们可以监控这个线程是否完成,上面的示例中主线程会一直等待这个新创建的线程直到它返回,其实只要是Future提供的接口,我们在FutureTask中都可以使用,这极大的方便了我们,Future在并发编程中的意义极为重要,Future代表一个未来会发生的东西,它是一种暗示,一种占位符,它示意我们它可能不会立即得到结果,因为它的任务还在运行,但是我们可以得到一个对这个线程的监控对象。
我们可以对线程的执行做一些判断,甚至是控制,比如,如果我们觉得我们等了太久,并且我们觉得没有必要再等待下去的时候,就可以将这个Task取消,还有一点需要提到的是,Future代表它可能正在运行,也可能已经返回,当然Future更多的暗示你可以在等待这个结果的同时可以使用其他的线程做一些其他的事情,当你真的需要这个结果的时候再来获取就可以了,这就是并发,理解这一点非常重要。