线程池

冷不防 2023-01-02 05:26 4阅读 0赞

# 线程池 #

## 概述： ##

用来存放线程对象的进行统一管理的一个容器，就叫做线程池。

第三方提供的一种工具，当我们需要线程对象做事情的时候找线程池获取对象帮我们做事情就ok，做完之后把对象还回去。

**实际使用**：我们要做事情只需要把线程任务给线程池，线程池派线程对象帮忙做事情

# Executors #

## 概述： ##

工具类，可以通过他特有的方法获取到线程池对象，获取到线程池对象就相当于获取到了线程对象，只需要把要线程做的事交给线程池就ok

## 功能： ##

### 1、newSingleThreadExecutor() ###

> 获取一个只有一个线程对象的线程池对象

### 2、 newFixedThreadPool(int num) ###

> 获取一个指定个数线程对象的线程池对象

### ExcutorService：就是线程池 ###

## 方法： ##

### 1、submit(Runnable r)： ###

> 提交线程任务对象给线程池

### 2、shutdown()： ###

> 关闭线程池【把提交的所有的任务执行完毕关闭线程池】

### 3、shutdownNow() ###

> 关闭线程池【把正在执行的任务执行完关闭线程池】

## 步骤： ##

1、获取线程池对象  
2、创建线程任务对象  
3、把任务对象提交给线程池对象  
4、关闭线程池【实际开发不需要我们关】

**代码示例：**

import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class ExecutorsDemo {
        
    	public static void main(String[] args) {
        
    		
    		//1、获取线程池对象
    		//	获取一个只有一个线程对象的线程池对象
    		ExecutorService pool1 = Executors.newSingleThreadExecutor();
    		//获取一个指定个数线程对象的线程池对象
    		ExecutorService pool2 = Executors.newFixedThreadPool(3);
    		
    		//2、创建线程任务对象
    		Runnable r1 = new Runnable() {
        
    			public void run() {
        
    				System.out.println(Thread.currentThread().getName()+ "线程任务一");
    			}
    		};
    		
    		Runnable r2 = new Runnable() {
        
    			public void run() {
        
    				System.out.println(Thread.currentThread().getName() + "线程任务二");
    			}
    		};
    		Runnable r3 = new Runnable() {
        
    			public void run() {
        
    				System.out.println(Thread.currentThread().getName() + "线程任务三");
    			}
    		};
    		Runnable r4 = new Runnable() {
        
    			public void run() {
        
    				System.out.println(Thread.currentThread().getName() + "线程任务四");
    			}
    		};
    		
    		//3、提交线程任务给线程池
    //		pool1.submit(r1);
    //		pool1.submit(r2);
    //		pool1.submit(r3);
    //		pool1.submit(r4);
    		
    		pool2.submit(r1);
    		pool2.submit(r2);
    		pool2.submit(r3);
    		pool2.submit(r4);
    		
    		//关闭线程池（实际开发中不需要我们关）
    //		pool1.shutdown(); //执行完毕所有的提交任务 再关闭
    //		pool1.shutdownNow();  // 执行完正在执行的的任务 就关闭
    		pool2.shutdown(); //执行完毕所有的提交任务 再关闭
    //		pool2.shutdownNow();  // 执行完正在执行的的任务 就关闭
    	}
    
    }