Callable接口的说明

1. run（）方法可以拥有返回值

2. 方法可以抛出异常

3. 支持泛型的返回值

4. 需要借助 FutureTask 类，比如获取返回结果

Callable代码举例

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

//1. 创建一个实现 Callable 的实现类
class NumThread implements Callable <Integer> {
    //2. 实现 call 方法，将此线程需要执行的操作声明在 call() 中
    @Override
    public Integer call() throws Exception {
        int sum = 0;
        for (int i = 1; i <= 100; i++) {
            if (i % 2 == 0) {
                System.out.println(i);
                sum += i;
            }
        }
        return sum;
    }
}
public class CallableTest {
    public static void main(String[] args) {
        //3. 创建 Callable 接口实现类的对象
        NumThread numThread = new NumThread();
        //4. 将此 Callable 接口实现类的对象作为传递到 FutureTask 构造器中，创建 FutureTask 的对象
        FutureTask futureTask = new FutureTask(numThread);
        //5. 将 FutureTask 的对象作为参数传递到 Thread 类的构造器中，创建 Thread 对象，并调用 start()
        new Thread(futureTask).start();
        try{
            //6. 获取 Callable 中 call 方法的返回值
            //get()返回值即为 futureTask 构造器参数 Callable 实现类重写的 call() 的返回值
            Object sum = futureTask.get();
            System.out.println("总和为: " + sum);
        }catch (InterruptedException e){
            e.printStackTrace();
        }catch (ExecutionException e){
            e.printStackTrace();
        }
    }
}

其他创建线程的方式：

【Java笔记】多线程的创建与使用（Thread与Runnable）_lijibai.的博客-CSDN博客

【Java笔记】使用线程池创建线程：https://blog.csdn.net/lijibai_/article/details/123860756

0 条评论