Java设计模式实战：线程池案例

原创﹏ヽ暗。殇╰゛Y 2024-11-14 15:15 92阅读 0赞

线程池是Java并发编程中常用的设计模式，它提供了重复使用已有工作线程的机制，避免了频繁创建和销毁线程的开销。

以下是一个简单的Java线程池案例，我们使用Apache Commons Lang库的Executors类来创建一个线程池：

```java
import org.apache.commons.lang3.concurrent.ThreadPoolExecutor;

public class ThreadPoolExample {

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

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            Runnable task = new Task("Task " + i);
            executor.execute(task);
        }

// 关闭线程池，所有提交的任务都将完成
        executor.shutdown();

// 等待所有任务完成（阻塞）
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(100); // 模拟等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All tasks completed!");

}

static class Task implements Runnable {

private String name;

public Task(String name) {
            this.name = name;
        }

@Override
        public void run() {
            System.out.println("Task " + name + " started...");

try {
                Thread.sleep(2000); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

System.out.println("Task " + name + " completed!");

}
    }
}
```

这个例子中，我们创建了一个固定大小的线程池，然后提交了10个任务到线程池。每个任务都是一个模拟耗时操作的Runnable实例。

最后，我们等待所有任务完成（阻塞）。当所有任务都完成后，输出"All tasks completed!"。