结合FutureTask实现多线程
时间: 2023-05-28 08:06:55 浏览: 110
多线程实现
FutureTask是一个非常强大的多线程工具,可以用来实现异步任务和并发控制等功能。结合FutureTask可以实现多线程。
下面是一个简单的例子,演示如何使用FutureTask实现多线程:
```java
import java.util.concurrent.*;
public class FutureTaskDemo {
public static void main(String[] args) throws Exception {
// 创建一个Callable对象
Callable<String> callable = new Callable<String>() {
public String call() throws Exception {
// 模拟一个耗时的操作
Thread.sleep(5000);
return "Hello World!";
}
};
// 创建一个FutureTask对象
FutureTask<String> futureTask = new FutureTask<String>(callable);
// 创建一个线程对象,并启动
Thread thread = new Thread(futureTask);
thread.start();
// 主线程继续执行其他任务
System.out.println("主线程执行其他任务...");
// 等待异步任务完成,并获取结果
String result = futureTask.get();
System.out.println("异步任务的结果是:" + result);
}
}
```
在这个例子中,我们首先创建了一个Callable对象,它会模拟一个耗时的操作,并返回一个字符串。然后我们创建了一个FutureTask对象,并将Callable对象传递给它作为参数。接着我们创建了一个线程对象,并启动它。主线程继续执行其他任务,然后等待异步任务完成,并获取结果。
在这个例子中,我们使用了FutureTask的get方法,来等待异步任务完成,并获取结果。get方法会阻塞当前线程,直到异步任务完成并返回结果。如果异步任务抛出了异常,get方法会将异常重新抛出。如果不想阻塞当前线程,可以使用isDone方法来判断异步任务是否完成,或者使用get方法的重载方法,传递一个超时时间作为参数,来等待异步任务完成。
阅读全文