如何使用Java ExecutorService管理线程

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给执行的机制，同时提供了对执行过程的控制。以下是使用ExecutorService管理线程的一些基本步骤：

创建一个ExecutorService实例：
- 使用Executors类的静态工厂方法来创建不同类型的ExecutorService。例如，Executors.newFixedThreadPool(int nThreads)会创建一个固定大小的线程池。
提交任务：
- 使用execute(Runnable command)方法提交一个实现了Runnable接口的任务。
- 使用submit(Callable task)方法提交一个实现了Callable接口的任务，该方法返回一个Future对象，可以用来获取任务的执行结果。
控制任务的执行：
- 可以使用shutdown()方法来关闭ExecutorService，它会等待已经提交的任务完成后再关闭。
- 如果需要立即关闭并且不关心未完成的任务，可以使用shutdownNow()方法。
处理任务结果：
- 如果使用了submit()方法提交任务，可以通过返回的Future对象来检查任务是否完成，并获取其结果或取消任务。
监控线程池的状态：
- ExecutorService提供了一些方法来获取线程池的状态，如getActiveCount()、getCompletedTaskCount()、getTaskCount()等。

下面是一个简单的示例，展示了如何使用ExecutorService来管理线程：

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

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(2);

        // 提交一个Runnable任务
        executor.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("Task 1 is running on thread " + Thread.currentThread().getName());
            }
        });

        // 提交一个Callable任务
        Future future = executor.submit(new Callable() {
            @Override
            public String call() throws Exception {
                Thread.sleep(1000);
                return "Task 2 completed";
            }
        });

        // 获取Callable任务的结果
        try {
            String result = future.get();
            System.out.println(result);
        } catch (Exception e) {
            e.printStackTrace();
        }

        // 关闭线程池
        executor.shutdown();
    }
}

在这个例子中，我们创建了一个固定大小为2的线程池，提交了两个任务（一个Runnable和一个Callable），然后关闭了线程池。Callable任务的结果被获取并打印出来。

请注意，当使用ExecutorService时，应该小心处理异常，并确保在不再需要线程池时适当地关闭它，以避免资源泄露。