如何使用java Executor执行器实现并发控制

在Java中，Executor框架提供了一种将任务提交给线程池执行的方式，从而简化了并发编程。以下是如何使用Executor执行器实现并发控制的步骤：

1. 创建一个线程池

首先，你需要创建一个线程池。Java提供了几种不同类型的线程池，例如：

• Executors.newFixedThreadPool(int nThreads)：创建一个固定大小的线程池。
• Executors.newCachedThreadPool()：创建一个可缓存的线程池，适用于执行大量短期异步任务。
• Executors.newSingleThreadExecutor()：创建一个单线程的线程池。

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

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

2. 提交任务

接下来，你可以将任务提交给线程池执行。任务可以是实现了Runnable接口的对象，或者是返回结果的Callable对象。

import java.util.concurrent.Callable;
import java.util.concurrent.Future;

public class ThreadPoolExample {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newFixedThreadPool(5);

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

        // 提交一个Callable任务
        Future<String> future = executor.submit(new Callable<String>() {
            @Override
            public String call() throws Exception {
                System.out.println("Callable task is running on thread " + Thread.currentThread().getName());
                return "Result of Callable task";
            }
        });

        // 获取Callable任务的结果
        String result = future.get();
        System.out.println(result);

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

3. 控制并发

你可以通过调整线程池的大小来控制并发。例如，如果你希望同时运行的任务不超过10个，可以创建一个大小为10的线程池。

ExecutorService executor = Executors.newFixedThreadPool(10);

4. 处理异常

在多线程环境中，异常处理非常重要。你可以使用Future对象的get()方法来捕获和处理任务执行过程中抛出的异常。

try {
    String result = future.get();
    System.out.println(result);
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    System.out.println("Task was interrupted");
} catch (ExecutionException e) {
    System.out.println("Exception occurred in task: " + e.getCause());
}

5. 关闭线程池

在应用程序结束时，确保关闭线程池以释放资源。

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

通过以上步骤，你可以使用Java的Executor执行器实现并发控制。根据具体需求选择合适的线程池类型，并合理管理任务的提交和线程池的关闭。