解锁Android多线程的奥秘：深入探索Callable、Future和FutureTask

2024-01-04 06:19:13

在Android开发中，多线程技术是构建响应式且高性能应用程序的关键。在我们的多线程之旅中，我们已经探索了创建线程的两种传统方法：继承Thread类和实现Runnable接口。然而，本篇文章将带您踏上另一条道路，深入了解Callable、Future和FutureTask，它们是Java并发包中用于管理异步任务的强大工具。

Callable：异步任务的蓝图

Callable接口与Runnable接口类似，它定义了一个run()方法。但是，run()方法的返回值类型有所不同。对于Runnable来说，run()方法不返回任何值，而对于Callable，它可以返回一个泛型类型T的值。这使得Callable非常适合用于处理需要从任务中检索结果的情况。

Future：异步任务的占位符

Future接口表示一个异步计算的结果。它提供了一个get()方法，用于检索计算的返回值。当调用get()方法时，当前线程将被阻塞，直到结果可用。如果任务尚未完成，get()方法将一直阻塞，直到任务完成或被取消。

FutureTask：Callable和Future的完美结合

FutureTask类同时实现了Callable和Future接口，充当Callable任务和Future结果之间的桥梁。它包装了一个Callable实例，并在调用get()方法时执行Callable的run()方法。FutureTask还提供了其他有用方法，例如isDone()和cancel()，用于检查任务的状态或取消任务。

示例：使用Callable和FutureTask

以下示例展示了如何使用Callable、Future和FutureTask来创建一个异步任务，计算斐波那契数列的第n个元素：

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

class FibonacciCallable implements Callable<Long> {
    private int n;

    public FibonacciCallable(int n) {
        this.n = n;
    }

    @Override
    public Long call() {
        if (n <= 1) {
            return (long) n;
        }
        return FibonacciCallable.fib(n - 1) + FibonacciCallable.fib(n - 2);
    }

    private static long fib(int n) {
        if (n <= 1) {
            return (long) n;
        }
        return FibonacciCallable.fib(n - 1) + FibonacciCallable.fib(n - 2);
    }
}

public class FibonacciExample {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        int n = 10;
        FibonacciCallable callable = new FibonacciCallable(n);
        FutureTask<Long> futureTask = new FutureTask<>(callable);

        Thread thread = new Thread(futureTask);
        thread.start();

        long result = futureTask.get();
        System.out.println("Fibonacci number at position " + n + ": " + result);
    }
}