import java.util.concurrent.Callable; import java.util.concurrent.FutureTask; public class ThreeThread { public static void main(String[] args) { //工作线程 Worker worker = new Worker(); //使用 FutrueTask 包装 Callable 对象 FutureTask<Integer> ft = new FutureTask<>(worker); for (int i = 0; i < 10; i++) { System.out.println(Thread.currentThread().getName() + "循环变量i的值：" + i); if (i == 5) { new Thread(ft, "有返回值的线程").start(); } try { //获取线程返回值 System.out.println("子线程的返回值：" + ft.get()); } catch (Exception e) { e.printStackTrace(); } } } //创建 Callable 接口的实现类 public static class Worker implements Callable<Integer> { // Class 'Worker' must either be declared abstract or implement abstract method 'call()' in 'Callable' @Override public Integer call() throws Exception { int t = 0; for (; t < 10; t++) { System.out.println(Thread.currentThread().getName() + "循环变量t的值：" + t); } return t; } } }

这段代码是一个使用 FutureTask 包装 Callable 对象实现多线程的示例。程序中定义了一个 Worker 类，实现了 Callable 接口的 call() 方法，用于执行具体的业务逻辑并返回结果。在 main() 方法中，创建了一个 Worker 对象，然后使用 FutureTask 包装该对象，并启动一个新的线程执行该 FutureTask。在主线程中，通过调用 FutureTask 的 get() 方法来获取子线程的返回值，并输出到控制台。程序最终输出了主线程和子线程交替打印的循环变量的值，以及子线程的返回值。