Java中的线程池：如何避免资源浪费的实例

原创快来打我* 2024-12-11 04:36 12阅读 0赞

在Java中，线程池是一种管理和复用线程的方式。通过预创建一定数量的线程，当有新的任务需要执行时，只需要将任务放入队列，由线程池自动分配和处理，从而避免了频繁创建和销毁线程的资源浪费。

以下是一个简单的线程池实现例子（使用Java内置的ThreadPoolExecutor）：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个线程池，大小为5个线程
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            executor.submit(() -> {
                System.out.println("Task " + i + " is running on thread " + Thread.currentThread().getId());
                try {
                    Thread.sleep(1000); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + i + " completed on thread " + Thread.currentThread().getId());
            });
        }

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

// 验证任务是否已经完成
        while (!executor.isTerminated())) {
            try {
                Thread.sleep(1000); // 模拟检查频率
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

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

这个例子中，线程池使用了`ThreadPoolExecutor.newFixedThreadPool(5)`来创建，预设了5个线程。当有新的任务提交时，这些线程会去执行任务。任务完成后，线程会自动返回给线程池，等待下一次的任务分配。