实际上,使用 Callable 和 Future 创建线程,从 Java 5 开始,Java 提供了 Callable 接口,该接口怎么看都像是 Runnable 接口的增强版,Callable 接口提供了一个 call () 方法可以作为线程执行体,但 call () 方法比 run () 方法功能更强大。
以下是一个使用 Callable 和 Future 创建线程的 Java 多线程代码示例:
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableExample {
public static void main(String[] args) throws InterruptedException, ExecutionException {
ExecutorService executor = Executors.newSingleThreadExecutor(); // 创建线程池
Callable<String> callable = new MyCallable(); // 创建Callable任务
Future<String> future = executor.submit(callable); // 提交任务并获取Future对象
System.out.println("等待任务执行结果…");
String result = future.get(); // 获取任务执行结果,这是一个阻塞方法,直到任务执行完成才会返回结果
System.out.println("任务执行结果:" + result);
executor.shutdown(); // 关闭线程池
}
}
class MyCallable implements Callable<String> {
@Override
public String call() throws Exception {
Thread.sleep(3000); // 模拟耗时操作
return "Hello, World!";
}
}
在这个示例中,我们创建了一个 Callable 任务( MyCallable ),并将其提交给一个线程池( ExecutorService )。线程池会返回一个 Future 对象,我们可以使用它来获取任务的执行结果。在主线程中,我们调用 Future 对象的 get 方法来获取结果,这是一个阻塞方法,直到任务执行完成才会返回结果。最后,我们关闭线程池。




