多线程（25）Callable接口

矫情吗；* 2024-04-24 23:10 61阅读 0赞

`Callable`接口是Java并发包（`java.util.concurrent`）中的一部分，自Java 5开始引入。它代表了一个异步计算任务，这个任务可以调用并返回结果。`Callable`接口类似于`Runnable`，但它可以返回结果并且能够抛出检查异常。`Callable`通常与`ExecutorService`配合使用，提交给线程池执行，并返回一个`Future`对象来获取计算结果。

#### Callable接口的定义 ####

`Callable`接口定义非常简单，如下所示：

public interface Callable<V> {
        
        V call() throws Exception;
    }

这里的`V`是`Callable`任务执行后返回的结果类型。`call()`方法是执行任务的地方，它可以返回结果或抛出异常。

#### 如何使用Callable ####

实现`Callable`接口需要实现`call()`方法。下面是一个简单的示例：

Callable<Integer> task = new Callable<Integer>() {
        
        @Override
        public Integer call() throws Exception {
        
            int result = 0;
            // 模拟计算
            for (int i = 0; i < 100; i++) {
        
                result += i;
            }
            return result; // 返回计算结果
        }
    };

或者使用Java 8的lambda表达式简化：

Callable<Integer> task = () -> {
        
        int result = 0;
        for (int i = 0; i < 100; i++) {
        
            result += i;
        }
        return result;
    };

提交`Callable`任务给`ExecutorService`执行，并通过返回的`Future`对象来获取结果：

ExecutorService executor = Executors.newCachedThreadPool();
    Future<Integer> future = executor.submit(task);
    
    try {
        
        // 等待任务执行完成，并获取其结果
        Integer result = future.get();
        System.out.println("Result: " + result);
    } catch (InterruptedException | ExecutionException e) {
        
        e.printStackTrace();
    }
    
    executor.shutdown();

#### Callable与Runnable的比较 ####

*  **返回值**：`Runnable`接口的`run()`方法不返回任何值，而`Callable`的`call()`方法可以返回一个结果。
 *  **异常**：`Runnable`的`run()`方法不能抛出检查异常，只能内部处理或抛出非检查异常；`Callable`的`call()`方法可以抛出异常，异常可通过`Future.get()`方法传递给调用者。
 *  **用途**：`Runnable`适用于不需要返回结果或处理异常的并发任务；`Callable`适用于可能需要返回结果和处理异常的复杂并发任务。

#### 使用场景 ####

`Callable`接口适合处理需要返回结果的并发任务。例如，可能需要从多个并发任务中收集结果，然后汇总这些结果。`Callable`任务在各种场景下都非常有用，特别是那些计算密集型的任务，或者那些需要在任务完成时返回一个值的任务。通过与`ExecutorService`和`Future`结合使用，`Callable`提供了一种强大而灵活的并发编程模型。