import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; // ---------------------Begin------------------------ //tips: 输出语句为：Thread.currentThread().getName()+"的call()方法在运行" //定义一个实现Callable接口的实现类，类名必须命名为MyThread_callable class MyThread_callable implements Callable{ public Object call() throws Exception { return Thread.currentThread().getName()+"的call()方法在运行"; } } // ---------------------End------------------------ public class Java { public static void main(String[] args) throws InterruptedException, ExecutionException { // 创建Callable接口的实现类对象 MyThread_callable myThread3 = new MyThread_callable(); // 使用FutureTask封装Callable接口 FutureTask<Object> ft1 = new FutureTask<>(myThread3); // 使用Thread(Runnable target ,String name)构造方法创建线程对象 Thread thread1 = new Thread(ft1, "thread1"); // 创建并启动另一个线程thread2 FutureTask<Object> ft2 = new FutureTask<>(myThread3); Thread thread2 = new Thread(ft2, "thread2"); // ---------------------Begin------------------------ // 调用线程对象的start()方法启动线程 thread1.start(); thread2.start(); // 可以通过FutureTask对象的方法管理返回 Thread.currentThread().getName() + "的call()方法在运行" = FutureTask.get(); // ---------------------End------------------------ } }

代码中的问题是，在调用 FutureTask 的 get 方法时，缺少了对应的 FutureTask 对象。正确的写法应该是：

// 获取线程执行结果
Object result1 = ft1.get();
Object result2 = ft2.get();
System.out.println(result1);
System.out.println(result2);

此外，为了避免代码中的类型未定义，应该将 MyThread_callable 改为泛型类 MyThread_callable<T>，并在 Callable 接口中指定返回值类型。

class MyThread_callable<T> implements Callable<T> {
    public T call() throws Exception {
        return (T) (Thread.currentThread().getName() + "的call()方法在运行");
    }
}