如何使用Java的线程池进行资源管理

原创痛定思痛。 2024-09-16 06:03 66阅读 0赞

在Java中，我们可以使用`ExecutorService`来创建一个线程池。线程池可以有效地管理系统中的线程，避免了频繁创建和销毁线程的开销。

以下是一个简单的使用`ThreadPoolExecutor`创建线程池的例子：

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

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

// 提交任务到线程池执行
        for (int i = 0; i < 10; i++) {
            Runnable task = () -> {
                System.out.println("Task " + i + " is running by thread " + Thread.currentThread().getId());
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            };
            executor.execute(task);
        }

// 关闭线程池，不再接受新的任务
        executor.shutdown();

// 等待所有任务完成或超时
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 所有任务已经完成，清理资源
        executor.clear();

System.out.println("All tasks have been executed.");
    }
}
```

这个例子中，我们创建了一个固定大小为5的线程池。然后提交了10个任务到线程池执行。最后关闭线程池并清理资源。