java executor

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

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

        // 提交多个任务给线程池执行
        for (int i = 0; i < 10; i++) {
            Runnable worker = new WorkerThread("Task " + i);
            executor.execute(worker);
        }

        // 关闭线程池，不再接受新的任务，但会继续执行已提交的任务
        executor.shutdown();
        while (!executor.isTerminated()) {
            // 等待所有任务完成
        }
        System.out.println("Finished all threads");
    }
}

class WorkerThread implements Runnable {
    private String task;

    public WorkerThread(String s) {
        this.task = s;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + " Start. Task = " + task);
        try {
            Thread.sleep(2000); // 模拟任务执行时间
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + " End. Task = " + task);
    }
}

解释说明

1. 创建线程池：

   • Executors.newFixedThreadPool(3)：创建一个固定大小为3的线程池。这意味着最多同时有3个线程在运行。

2. 提交任务：

   • 使用executor.execute(worker)将任务提交给线程池。这里的worker是一个实现了Runnable接口的对象，表示一个可以在线程中执行的任务。

3. 关闭线程池：

   • executor.shutdown()：调用此方法后，线程池不再接受新的任务，但会继续执行已经提交的任务。
   • while (!executor.isTerminated())：等待所有任务完成。isTerminated()返回true表示所有任务都已完成。

4. 任务类：

   • WorkerThread类实现了Runnable接口，并重写了run方法。每个任务在run方法中执行自己的逻辑。这里简单地打印了任务开始和结束的信息，并使用Thread.sleep(2000)模拟任务执行时间。

这个示例展示了如何使用Java的ExecutorService来管理线程池和任务执行。