如何用Java ExecutorService实现并发控制

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方式。通过使用ExecutorService，你可以控制并发线程的数量，避免创建过多的线程，从而提高应用程序的性能和稳定性。

下面是一个简单的示例，展示了如何使用ExecutorService实现并发控制：

1. 首先，导入所需的包：

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

2. 创建一个实现了Runnable接口的任务类：

class MyTask implements Runnable {
    private int taskId;

    public MyTask(int taskId) {
        this.taskId = taskId;
    }

    @Override
    public void run() {
        System.out.println("Task " + taskId + " is running on thread " + Thread.currentThread().getName());
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Task " + taskId + " is completed");
    }
}

3. 在主类中创建一个ExecutorService实例，并提交任务：

public class Main {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，最多同时运行5个任务
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 提交10个任务
        for (int i = 0; i < 10; i++) {
            MyTask task = new MyTask(i);
            executorService.submit(task);
        }

        // 关闭线程池，不再接受新的任务
        executorService.shutdown();

        try {
            // 等待所有任务完成
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                // 超时后强制关闭线程池
                executorService.shutdownNow();
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
        }

        System.out.println("All tasks are completed");
    }
}

在这个示例中，我们创建了一个固定大小的线程池，最多同时运行5个任务。然后我们提交了10个任务，线程池会自动控制并发线程的数量。最后，我们关闭线程池并等待所有任务完成。

通过这种方式，你可以使用ExecutorService实现并发控制，提高应用程序的性能和稳定性。