线程的创建方式：使用 Callable 和 Future

线程的创建方式：使用 Callable 和 Future

在多线程编程中，线程的创建方式有多种。除了常见的继承Thread类和实现Runnable接口外，还可以使用Callable和Future来创建线程。本文将介绍使用Callable和Future的线程创建方式，并讨论其优势与用法。

1. Callable 接口

Callable接口是Java 5中新增的接口，位于java.util.concurrent包下。它是一个泛型接口，定义了一个call()方法，该方法可以返回一个结果，并且可以抛出异常。

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

相比于Runnable接口的run()方法，Callable接口的call()方法可以有返回值，并且可以抛出异常。

2. Future 接口

Future是一个接口，用于表示异步计算的结果。它提供了一些方法，以便获取异步计算的结果、取消计算或判断计算是否完成。

public interface Future<V> {
    boolean cancel(boolean mayInterruptIfRunning);
    boolean isCancelled();
    boolean isDone();
    V get() throws InterruptedException, ExecutionException;
    V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException;
}

通过Future接口，我们可以在创建线程时获取线程的执行结果，并且可以对任务进行取消或判断任务是否完成。

3. 使用 Callable 和 Future 创建线程

为了创建一个使用Callable和Future的线程，我们首先需要实现Callable接口，并实现其call()方法。在call()方法中，我们可以编写需要执行的任务，并返回任务的结果。然后，我们可以使用ExecutorService类来提交Callable任务，并通过Future接口获取任务的执行结果。

import java.util.concurrent.*;
public class CallableThreadExample implements Callable<String> {
    public String call() throws Exception {
        // 在这里编写需要执行的任务
        return "任务执行成功！";
    }
    public static void main(String[] args) {
        // 创建一个线程池
        ExecutorService executorService = Executors.newFixedThreadPool(1);
        // 创建Callable任务
        CallableThreadExample callableThread = new CallableThreadExample();
        // 提交任务并获取Future对象
        Future<String> future = executorService.submit(callableThread);
        try {
            // 获取任务的执行结果
            String result = future.get();
            System.out.println(result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
        // 关闭线程池
        executorService.shutdown();
    }
}

在上述示例中，我们实现了一个名为CallableThreadExample的类，该类实现了Callable接口。在call()方法中，我们编写了需要执行的任务，并返回了字符串”任务执行成功！”。在main()方法中，我们创建了一个线程池，然后使用ExecutorService类的submit()方法提交Callable任务，并通过Future接口获取任务的执行结果。最后，我们通过调用线程池的shutdown()方法来关闭线程池。

通过使用Callable和Future，我们可以更方便地创建线程，并且可以获取到线程的执行结果。这种方式在需要获取线程执行结果或进行任务取消的场景下非常有用。

1. Callable 接口

2. Future 接口

3. 使用 Callable 和 Future 创建线程

江明涛