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(); new Thread(ft, "1").start(); } } } //创建 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对象ft来包装Callable接口实现类Worker的实例对象worker，并将ft传递给一个新线程，并启动该线程。当循环变量i的值等于5时，会启动两个新线程，都使用了同一个FutureTask对象ft，因此会输出两个子线程信息，但是它们都在执行同一个Callable对象的call()方法，因此输出的内容是相同的。在主线程中，没有调用ft.get()方法获取子线程的返回值，因此不会输出子线程的返回值。

相关问题

how should i finish this package step2; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; // ---------------------Begin------------------------ //tips: 输出语句为：Thread.currentThread(

).getName() + ": " + i // 实现Callable接口来创建线程 class MyCallable implements Callable<Integer> { @Override public Integer call() throws Exception { int sum = 0; for (int i = 1; i <= 100; i++) { System.out.println(Thread.currentThread().getName() + ": " + i); sum += i; } return sum; } } public class Main { public static void main(String[] args) throws InterruptedException, ExecutionException { // 创建Callable对象 MyCallable myCallable = new MyCallable(); // 将Callable对象封装成一个FutureTask对象 FutureTask<Integer> futureTask = new FutureTask<>(myCallable); // 创建线程并启动 Thread thread = new Thread(futureTask); thread.start(); // 获取线程执行结果 int result = futureTask.get(); System.out.println("线程执行结果为：" + result); } } // ----------------------End-------------------------

package step2; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; // ---------------------Begin------------------------ //tips: 输出语句为：Thread.currentThread().getName()+"的call()方法在运行" //定义一个实现Callable接口的实现类，类名必须命名为MyThread_callable // ---------------------End------------------------ public class CallableExample { 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对象的方法管理返回值 try{ thread1=futureTask.get(); thread2=futureTask.get(); }catch{ } // ---------------------End------------------------ } }

代码中有一些错误，我来帮你指出来：

1. 在try-catch语句中，应该指定捕获的异常类型，正确的写法是：

try {
    thread1 = (Thread) ft1.get();
    thread2 = (Thread) ft2.get();
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

2. 在代码注释中，类名应该是 MyThread_callable 而不是 MyThread。

3. 在代码注释中，输出语句应该是 Thread.currentThread().getName() + "的call()方法在运行"。

4. 在代码注释中，应该使用 // 注释单行注释，而不是 /* ... */ 注释多行注释。

5. 在main方法中，创建线程对象时应该使用 FutureTask<Object> ft2 = new FutureTask<>(myThread3) 而不是 FutureTask<Object> ft2 = new FutureTask<>(myThread2)。

6. 在main方法中，获取返回值时应该使用 ft1.get() 和 ft2.get() 而不是 futureTask.get()。

7. 在main方法中，创建线程对象时应该使用 new Thread(ft1, "thread1") 和 new Thread(ft2, "thread2") 而不是 new Thread(myThread3, "thread1") 和 new Thread(myThread3, "thread2")。