一个实例理解线程池工作原理

曾经终败给现在 2022-06-06 06:15 250阅读 0赞

线程池初始化成功之后，当任务提交上来，线程池中的线程是如何构建的。

下面给出构建线程池的三个重要参数：

核心线程数：corePoolSize  
最大线程数：maximumPoolSize  
队列大小：workQueueSize

线程池中的线程，开始是没有的，当任务提交上来之后，会开始创建，当达到核心线程数之后，进入队列，如果队列已经满了，那么开始创建新的线程，直到达到最大线程数，这时候，如果没有线程执行完成，还有新的任务加入进来，那么线程池会开启拒绝策略。

下面通过一段代码来演示这个原理。我们假定核心线程数是5，队列大小5，最大线程数是10。这里我们假定任务数是15个，那么正好模拟这个不出现异常的线程池工作场景。

package com.xxx.threadpool;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    public class ThreadPoolDemo {
    
    	public static void main(String[] args) {
    		int corePoolSize = 5;
    		int maximumPoolSize = 10;
    		long keepAliveTime = 200;
    		TimeUnit unit = TimeUnit.MILLISECONDS;
    		ArrayBlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<Runnable>(5); 
    		ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, 
    				maximumPoolSize, 
    				keepAliveTime, 
    				unit, 
    				workQueue);
    		for(int i=0;i<15;i++){
    			executor.execute(new MyThread(i));
    			System.out.println("线程池中线程数目："+executor.getPoolSize()+
    			"，队列中等待执行的任务数目："+executor.getQueue().size()+
    			"，已经执行完的别的任务数目："+executor.getCompletedTaskCount());
    		}
    		executor.shutdown();
    	}
    
    }
    
    class MyThread implements Runnable{
    	
    	private int taskNum;
    	public MyThread(int taskNum) {
    		this.taskNum = taskNum;
    	}
    	
    	@Override
    	public void run() {
    		System.out.println("正在执行任务 "+taskNum);
    		try {
    			Thread.sleep(4000);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		System.out.println("任务 "+taskNum+" 执行完毕。");
    	}
    }

执行这段代码打印信息如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaW5pZmk_size_16_color_FFFFFF_t_70][]

这里我们设置的线程任务总数刚好是15=maximumPoolSize(10)+workQueueSize(5)。所以程序没有出现异常， 我们如果设置的线程任务数大于15，那么线程池会开启拒绝策略，如下打印信息：

Exception in thread "main" java.util.concurrent.RejectedExecutionException: Task com.xxx.threadpool.MyThread@6bc7c054 rejected from java.util.concurrent.ThreadPoolExecutor@232204a1\[Running, pool size = 10, active threads = 10, queued tasks = 5, completed tasks = 0\]  
    at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047)  
    at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)  
    at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)  
    at com.xxx.threadpool.ThreadPoolDemo.main(ThreadPoolDemo.java:19)

到此为止，我们通过实例演示了线程池线程创建的过程，加深了我们对线程池的理解和认识。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaW5pZmk_size_16_color_FFFFFF_t_70]: /images/20220606/6ff50a7bfe304ece8981ba2730f9249e.png