Java线程池中的核心线程和最大线程数量设置问题实例

原创「爱情、让人受尽委屈。」 2024-11-12 07:15 59阅读 0赞

在Java中，线程池（`ExecutorService`）是一种执行器（Executor），用于在一个后台线程中执行任务。线程池的主要目的是减少在创建和销毁线程时所产生的性能开销。通过重用已经创建的线程来执行新的任务，线程池提高了程序的响应速度，并且提供了更好的系统资源管理。

线程池中的核心线程数（core pool size）和最大线程数（maximum pool size）是两个重要的参数，它们定义了线程池的行为：

- **核心线程数（core pool size）**：线程池中始终保持的线程数量，即使它们处于空闲状态。当新任务被提交时，线程池会首先尝试使用空闲的核心线程来执行任务。

- **最大线程数（maximum pool size）**：线程池中允许的最大线程数量。如果所有核心线程都在忙碌，并且工作队列已满，那么线程池会创建新的线程，直到达到这个最大值。

下面是一个简单的Java线程池设置核心线程和最大线程数量的实例：

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

public class ThreadPoolExample {
 public static void main(String[] args) {
// 设置核心线程数为5，最大线程数为10int corePoolSize =5;
int maximumPoolSize =10;

// 创建一个固定大小的线程池ExecutorService threadPool = Executors.newFixedThreadPool(corePoolSize, r -> {
Thread t = new Thread(r);
t.setName("CustomThread-" + t.getId());
 return t;
 });

// 提交任务到线程池 for (int i =0; i <15; i++) {
 threadPool.execute(new Runnable() {
@Override public void run() {
 System.out.println(Thread.currentThread().getName() + " is running");
 try {
 TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
 }
 }
 });
 }

// 关闭线程池 threadPool.shutdown();
 }
}
```在这个例子中，我们创建了一个固定大小的线程池，核心线程数为5，最大线程数为10。这意味着线程池会始终保持5个线程，即使它们处于空闲状态。如果所有5个核心线程都在忙碌，并且任务队列已满（默认情况下，`Executors.newFixedThreadPool`创建的线程池使用一个无界队列），那么线程池会创建新的线程，直到达到最大线程数10。

请注意，这个例子中的线程池使用的是无界队列，这意味着如果任务提交的速度超过了线程处理的速度，那么队列中可能会积累大量的任务，从而导致内存溢出。在实际应用中，你可能需要根据具体需求选择合适的队列类型，例如有界队列或者同步队列。