资源管理疑难：Java线程池和缓冲池的使用示例

原创水深无声 2024-10-06 15:30 50阅读 0赞

Java线程池（Thread Pool）和缓冲池（Buffer Pool）是两种常见的资源管理策略，主要用于提高系统性能和资源利用率。

1. 线程池示例：

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

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

// 提交任务到线程池执行
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.submit(() -> {
                System.out.println("Task " + index + " is running.");
                try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + index + " has completed.");
            });
        }

// 关闭线程池，释放资源
        executor.shutdown();
        try {
            // 等待所有任务完成或超时
            executor.awaitTermination(30, TimeUnit.SECONDS));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

2. 缓冲池示例：

```java
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class BufferPoolExample {
    public static void main(String[] args) {
        // 创建一个线程安全的缓冲队列，容量为5
        BlockingQueue<String> queue = new LinkedBlockingQueue<>(5);

// 提交任务到缓冲队列，当队列满时阻塞
        for (int i = 0; i < 10; i++) {
            final int index = i;
            queue.put(String.format("Task %d from BufferPool", index)));
            System.out.println("Submitted task " + index);
        }

// 此时，缓冲队列满且有新的任务需要提交
        // 通过调用clear()方法清空缓冲队列
        queue.clear();

// 最后，再次尝试将新任务提交到已清空的缓冲队列
        for (int i = 10; i < 20; i++) {
            final int index = i;
            try {
                queue.put(String.format("Task %d from BufferPool", index))));
                System.out.println("Submitted task " + index);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 关闭缓冲队列，释放资源
        queue.close();
    }
}
```

这些示例展示了如何使用Java的线程池和缓冲池来提高系统的并发能力和内存管理效率。