Java并发编程：线程池的创建与使用

原创小灰灰 2024-09-22 08:06 99阅读 0赞

在Java并发编程中，线程池是一种常用的管理和复用线程的方式。以下是线程池的创建和使用的步骤：

1. **创建线程池**：
   - `Executors`类提供了一些静态方法来创建线程池。
   ```java
   // 创建一个固定大小的线程池
   ThreadPoolExecutor executor = Executors.newFixedThreadPool(5);

// 创建一个无界的线程池，自动管理线程
   executor = Executors.newCachedThreadPool();
   ```

2. **提交任务到线程池**：
   - 使用`execute(Runnable task)`方法将任务提交给线程池。
   ```java
   // 提交一个打印'Hello, World!'的任务到线程池
   Future<String> future = executor.submit(new Runnable() {
       @Override
       public void run() {
           System.out.println("Hello, World!");
       }
   }));
   
   // 等待任务完成并获取结果
   try {
       System.out.println(future.get()); // 输出：Hello, World!
   } catch (InterruptedException | ExecutionException e) {
       e.printStackTrace();
   }
   ```

3. **关闭线程池**：
   - 使用`shutdown()`方法停止线程池，但是已经提交的任务会继续执行。
   ```java
   executor.shutdown(); // 关闭线程池
   ```
   
4. **等待线程池完全关闭**：
   - 如果希望线程池在所有任务完成后才完全关闭，可以使用`awaitTermination(long timeout, TimeUnit unit))`方法设置超时时间。
   ```java
   try {
       executor.awaitTermination(10, TimeUnit.SECONDS); // 设置超时时间为10秒
   } catch (InterruptedException | ExecutionException e) {
       e.printStackTrace();
   }
   ```

以上就是使用Java创建和管理线程池的基本步骤。