Java Executor执行器如何实现异步任务

在Java中，Executor框架是一个用于管理和控制线程的工具，它可以帮助我们更方便地实现异步任务。要使用Executor执行器实现异步任务，你需要遵循以下步骤：

1. 创建一个ExecutorService实例：ExecutorService是Executor框架的核心接口，它提供了管理线程池和任务提交的方法。你可以使用Executors工具类创建一个ExecutorService实例，例如：

ExecutorService executorService = Executors.newFixedThreadPool(5);

这里，我们创建了一个固定大小的线程池，最多可以同时运行5个线程。

2. 创建一个Runnable或Callable任务：Runnable和Callable接口都表示一个可以被执行的任务。Runnable接口的run()方法没有返回值，而Callable接口的call()方法可以返回一个结果。以下是一个简单的Runnable任务示例：

class MyTask implements Runnable {
    @Override
    public void run() {
        System.out.println("Task is running in " + Thread.currentThread().getName());
    }
}

3. 提交任务给ExecutorService：使用ExecutorService的submit()方法将任务提交给执行器。submit()方法接受一个Runnable或Callable对象，并返回一个Future对象，该对象可以用于获取任务的执行结果或取消任务。

Future<?> future = executorService.submit(new MyTask());

4. 关闭ExecutorService：在所有任务完成后，你应该关闭ExecutorService以释放资源。可以使用shutdown()方法来优雅地关闭执行器，它会等待所有已提交的任务完成后再关闭。如果你想要立即关闭执行器，可以使用shutdownNow()方法，但这可能会导致正在执行的任务被中断。

executorService.shutdown();

下面是一个完整的示例，演示了如何使用Executor执行器实现异步任务：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class AsyncTaskExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        for (int i = 0; i < 10; i++) {
            Future<?> future = executorService.submit(new MyTask());
            try {
                // 等待任务完成，最多等待1秒
                if (!future.isDone()) {
                    future.get(1, TimeUnit.SECONDS);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        executorService.shutdown();
    }

    static class MyTask implements Runnable {
        @Override
        public void run() {
            System.out.println("Task is running in " + Thread.currentThread().getName());
            try {
                // 模拟任务耗时
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

在这个示例中，我们创建了一个固定大小为5的线程池，并提交了10个任务。每个任务都会打印一条消息并休眠500毫秒。我们使用Future.get()方法等待任务完成，最多等待1秒。最后，我们关闭ExecutorService。