如何正确使用java Executor执行器

Java Executor框架是一个用于管理线程的工具，它可以帮助我们更有效地执行并发任务。以下是如何正确使用Java Executor执行器的步骤：

1. 导入必要的包：

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

2. 创建一个ExecutorService实例：

ExecutorService executorService = Executors.newFixedThreadPool(int nThreads);

这里，nThreads是你希望创建的线程数量。你可以根据你的应用程序需求来设置这个值。

3. 将任务提交给ExecutorService：

executorService.submit(new Runnable() {
    @Override
    public void run() {
        // 在这里编写你的任务代码
    }
});

或者，如果你有一个实现了Callable接口的任务，你可以这样提交：

Future<ResultType> future = executorService.submit(new Callable<ResultType>() {
    @Override
    public ResultType call() throws Exception {
        // 在这里编写你的任务代码
        return result;
    }
});

4. 关闭ExecutorService： 在所有任务都完成后，你应该关闭ExecutorService以释放资源。这可以通过调用shutdown()方法来实现：

executorService.shutdown();

如果你希望在关闭前等待所有任务完成，可以使用awaitTermination()方法：

try {
    if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
        executorService.shutdownNow();
    }
} catch (InterruptedException e) {
    executorService.shutdownNow();
}

下面是一个简单的示例，展示了如何使用ExecutorService执行多个任务：

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

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

        for (int i = 0; i < 5; i++) {
            final int taskId = i;
            executorService.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println("Task " + taskId + " is running on thread " + Thread.currentThread().getName());
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("Task " + taskId + " is completed");
                }
            });
        }

        executorService.shutdown();
        try {
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                executorService.shutdownNow();
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
        }
    }
}

这个示例创建了一个固定大小的线程池，提交了5个任务，并在所有任务完成后关闭了ExecutorService。