四种常用线程池

Love The Way You Lie 2024-04-18 12:39 54阅读 0赞

**目录**

一、什么是线程池

二、线程池作用

三、四种线程池代码

--------------------

### ** 一、什么是线程池** ###

在 java.util.concurrent.Executors类中提供了一个 Executor接口的实现用于创建线程池，线程池就是我们先创建一批线程，不会等到需要的时候再去创建，而这些线程的集合就称为线程池。当需要线程时去线程池中拿，如果线程池没有线程了再新建线程。

### **二、线程池作用** ###

1、减少线程创建和销毁过程中消耗的系统资源；

2、可以根据系统的承受能力，调整线程池中工作线线程的数目，防止因为消耗过多的内存。

### **三、四种线程池代码** ###

package com.lzw.demo;
    
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;
    
    public class ExecutorsTest {
    
    	public static void main(String[] args) {
    		//CachedThread();
    		//FixedThread();
    		//ScheduledThread();
    		SingleThread();
    	}
    
    	/**
    	 *  可缓冲线程池：先查看池中有没有以前建立的线程，如果有，就直接使用。如果没有，就建一个新的线程加入池中。
    	 *  线程池大小为无限大
    	 *  适用：执行一些生存期很短的异步型任务
    	 */
    	public static void CachedThread() {
    		// 可缓存线程池
    		ExecutorService pool = Executors.newCachedThreadPool();
    		for (int i = 0; i < 10; i++) {
    			try {
    				Thread.sleep(100);
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    			pool.execute(new Runnable() {
    				@Override
    				public void run() {
    					System.out.println(Thread.currentThread().getName() + "正在被执行");
    				}
    			});
    		}
    	}
    	
    	/**
    	 * 固定个数线程池：创建一个可重用固定个数的线程池，以共享的无界队列方式来运行这些线程。
    	 */
    	public static void FixedThread(){
    		//固定个数线程池
    		ExecutorService pool = Executors.newFixedThreadPool(5);
    		for (int i = 0; i < 10; i++) {
    			try {
    				Thread.sleep(100);
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    			pool.execute(new Runnable() {
    				@Override
    				public void run() {
    					System.out.println(Thread.currentThread().getName() + "正在被执行");
    				}
    			});
    		}
    	}
    	
    	/**
    	 * 	 周期线程池：创建一个定长线程池，支持定时及周期性任务执行
    	 */
    	public static void ScheduledThread(){
    		ScheduledExecutorService pool = Executors.newScheduledThreadPool(10);
    		pool.scheduleAtFixedRate(new Runnable() {
    			@Override
    			public void run() {
    				   System.out.println("延迟2秒后每5秒执行一次");
    			}
    		},2,5, TimeUnit.SECONDS);
    		
    	}
    	
    	/**
    	 * 单任务线程池：
    	 * 会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
    	 */
    	public static void SingleThread(){
    		ExecutorService pool = Executors.newSingleThreadExecutor();
    		for (int i = 0; i < 10; i++) {
    			final int index = i;
    			pool.execute(new Runnable() {
    				
    				@Override
    				public void run() {
    					try {
    						//结果依次输出，相当于顺序执行各个任务
    						System.out.println(Thread.currentThread().getName()+"正在被执行,打印的值是:"+index);
    						Thread.sleep(1000);
    					} catch (InterruptedException e) {
    						e.printStackTrace();
    					}
    				}
    			});
    		}
    	}
    	
    }