Java中的并发工具类——ExecutorService实例分析

原创叁歲伎倆 2024-09-17 17:24 83阅读 0赞

在Java编程中，`ExecutorService`是Java并发包（java.util.concurrent）中的一种工具类。它主要用于管理和调度线程执行任务。

以下是一些关于`ExecutorService`的实例分析：

1. **创建 ExecutorService 实例**：
   ```java
   // 创建一个单线程池
   ExecutorService singleThreadPool = Executors.newSingleThreadExecutor();

// 创建一个固定大小的线程池
   ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10));

// 关闭线程池，所有提交但尚未开始的任务将丢失
   singleThreadPool.shutdown();
   ```
   
2. **使用submit()方法提交任务**：
   ```java
   // 提交一个Runnable任务到线程池中执行
   Future<String> future = fixedThreadPool.submit(new Task("Hello World")));

// 等待任务完成，获取返回值
   try {
       String result = future.get();
       System.out.println(result);  // 输出 "Hello World"
     } catch (TimeoutException e) {
       System.out.println("Task took too long to complete.");
     } catch (InterruptedException | ExecutionException e) {
       System.out.println("Error occurred during task execution: " + e.getMessage());
     }
   ```
   
3. **关闭 ExecutorService**：
   由于线程池维护着一些状态，如工作队列等，因此在不使用线程池的情况下，应该调用`shutdown()`方法来释放资源，但线程池中的任务不会被取消。如果想彻底停止执行所有提交的任务，可以调用`shutdownNow()`方法。

总结来说，Java并发工具类`ExecutorService`提供了一种高效的管理线程执行任务的方式。