Callable 接口：多线程编程的利器

2023-11-30 04:14:27

Java Callable接口实现多线程的方式

在 Java 1.5 版本之前，创建线程主要有两种方式：继承 Thread 类或实现 Runnable 接口。无论是哪种方式，最终都需要调用 Thread 类中的 start() 方法，向操作系统请求 I/O、CPU 等资源。

然而，Thread 类中的 run() 方法没有返回值，如果需要获取线程执行结果，则必须借助其他机制，如共享变量或队列。这使得多线程编程变得繁琐且容易出错。

为了解决这个问题，Java 1.5 引入了 Callable 接口，它允许线程执行一个带有返回值的任务。Callable 接口中定义了一个 call() 方法，它与 run() 方法类似，但可以返回一个结果。

实现 Callable 接口

要实现 Callable 接口，需要创建一个类并实现其 call() 方法。call() 方法应该包含需要执行的任务的逻辑，并返回一个结果。

import java.util.concurrent.Callable;

public class MyCallable implements Callable<Integer> {

    @Override
    public Integer call() throws Exception {
        // 执行任务并返回结果
        return 10;
    }
}

使用 FutureTask

要使用 Callable 接口，需要创建一个 FutureTask 对象。FutureTask 是一个实现 Future 接口的类，它可以封装一个 Callable 任务。

import java.util.concurrent.FutureTask;

public class Main {

    public static void main(String[] args) {
        MyCallable callable = new MyCallable();
        FutureTask<Integer> futureTask = new FutureTask<>(callable);

        // 启动一个新线程执行任务
        new Thread(futureTask).start();

        // 从 FutureTask 中获取结果
        try {
            Integer result = futureTask.get();
            System.out.println(result);  // 输出 10
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}