Java Executor执行器如何实现并发控制

在Java中，Executor框架提供了一种将任务提交给线程池执行的方式。通过使用Executor，可以轻松地实现并发控制。以下是使用Java Executor实现并发控制的几种方法：

1. 使用Executors工具类创建线程池：

Java提供了Executors工具类，可以方便地创建不同类型的线程池。例如，创建一个固定大小的线程池：

ExecutorService executor = Executors.newFixedThreadPool(10);

这里，我们创建了一个最大线程数为10的线程池。

2. 提交任务给线程池：

使用execute()或submit()方法将任务提交给线程池。execute()方法接受一个Runnable对象，而submit()方法接受一个Callable对象。

executor.execute(new MyTask());

或者

Future<?> future = executor.submit(new MyCallableTask());

3. 控制并发任务的数量：

可以通过调整线程池的大小来控制并发任务的数量。例如，如果你想同时运行5个任务，可以创建一个最大线程数为5的线程池：

ExecutorService executor = Executors.newFixedThreadPool(5);

4. 使用Semaphore实现并发控制：

Semaphore是一个计数信号量，可以用来限制同时访问特定资源的线程数量。例如，如果你想限制同时运行的任务数量为3，可以使用以下代码：

Semaphore semaphore = new Semaphore(3);

executor.execute(new Runnable() {
    @Override
    public void run() {
        try {
            semaphore.acquire();
            // 执行任务
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            semaphore.release();
        }
    }
});

5. 使用CountDownLatch实现并发控制：

CountDownLatch是一个同步辅助类，允许一个或多个线程等待直到一组操作完成。例如，如果你想在执行多个任务之前等待所有任务完成，可以使用以下代码：

CountDownLatch latch = new CountDownLatch(3);

executor.execute(new Runnable() {
    @Override
    public void run() {
        try {
            // 执行任务
        } finally {
            latch.countDown();
        }
    }
});

// 等待所有任务完成
latch.await();

通过这些方法，可以使用Java Executor实现并发控制。在实际应用中，可以根据需要选择合适的方法。