java executorservice

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

public class ExecutorServiceExample {

    public static void main(String[] args) {
        // 创建一个固定大小的线程池，这里设置为3个线程
        ExecutorService executor = Executors.newFixedThreadPool(3);

        // 提交多个任务给线程池执行
        for (int i = 0; i < 5; i++) {
            final int taskNumber = i;
            executor.submit(() -> {
                System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
                try {
                    // 模拟任务执行时间
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                    System.out.println("Task " + taskNumber + " was interrupted");
                }
                System.out.println("Task " + taskNumber + " is completed");
            });
        }

        // 关闭线程池，不再接受新的任务
        executor.shutdown();
        try {
            // 等待所有任务完成，最多等待1分钟
            if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
                System.out.println("Not all tasks completed within the timeout period");
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.out.println("ExecutorService was interrupted while waiting for tasks to complete");
        }
    }
}

解释说明

1. 创建线程池:

   • 使用 Executors.newFixedThreadPool(3) 创建了一个固定大小为3的线程池。这意味着线程池中最多有3个线程可以并发执行任务。

2. 提交任务:

   • 使用 executor.submit() 方法向线程池提交任务。每个任务是一个实现了 Runnable 接口的匿名类或 lambda 表达式。
   • 在这个例子中，我们提交了5个任务，每个任务会打印其编号和当前执行的线程名称，并模拟2秒钟的任务执行时间。

3. 关闭线程池:

   • 调用 executor.shutdown() 方法来关闭线程池，这表示不再接受新的任务，但会继续执行已经提交的任务。

4. 等待任务完成:

   • 使用 executor.awaitTermination(60, TimeUnit.SECONDS) 方法等待所有任务完成，最多等待60秒。如果在指定时间内所有任务都完成了，则返回 true；否则返回 false。

5. 处理中断:

   • 如果在等待期间线程被中断，捕获 InterruptedException 并处理中断情况。