线程的生命周期和线程的通讯

古城微笑少年丶 2023-01-02 05:23 143阅读 0赞

# 线程的生命周期 #

## 概述： ##

线程从创建到执行完毕的过程就叫做生命周期，整个周期中会不同的状态，状态之间会发生相互转换的现象。

## 状态罗列： ##

新建：线程创建出来但是没有开启  
就绪：start方法开启了线程，  
运行：得到CPU正常的执行  
阻塞：得到cpu开始执行但是中间受到影响不能正常的执行  
死亡：线程正常执行完毕结束

## Thread类的状态项： ##

NEW:新建  
RUNNABLE：运行和就绪  
BLOCKED：锁阻塞  
WAITING：无限等待  
TIMED\_WAITING：计时等待  
TERMINATED：死亡

想要获取线程的状态值通过方法getState方法获取

**状态转换图**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FfWmVuZ18_size_16_color_FFFFFF_t_70_pic_center]

# 多线程的通信问题【消费者机制】 #

## 概述： ##

多线程进行协作工作的时候采用的一种通信方式，这样可以使线程之间可以交替的执行，有效 的完成之间协作的事情。

## 实现： ##

借助于锁对象的等待和唤醒功能控制线程的状态完成通信

等待功能：就是Object类中的wait方法

唤醒功能：就是Object类中的notify、notifyAll方法

## 案例： ##

包子铺卖包子【有包子不做包子 等人来吃包子 没有包子就做包子】

人吃包子【有包子就吃，没有包子等包子铺做包子】

**代码示例：**

包子铺：
    import java.util.ArrayList;
    
    public class BaoZi extends Thread{
        
    	
    	//创建集合，用来存放包子
    	private ArrayList<String> list;
    
    	public BaoZi(ArrayList<String> list) {
        
    		super();
    		this.list = list;
    	}
    	
    	@Override
    	public void run() {
        
    		
    		while (true) {
        
    			//包子铺和吃包子同时操作list，有安全问题
    			synchronized (list) {
        
    				//判断是否有包子
    				if (list.size() == 0) {
        
    					//没有包子，做包子
    					//设置做包子的时间
    					try {
        
    						Thread.sleep(1000);
    					} catch (InterruptedException e) {
        
    						e.printStackTrace();
    					}
    					list.add("包子"); //做好包子
    					System.out.println("包子做好了");
    					//通过锁对象，唤醒线程,通知人来吃包子
    					list.notify();
    				}else {
        
    					//有包子，等待
    					try {
        
    						list.wait();
    					} catch (InterruptedException e) {
        
    						e.printStackTrace();
    					}
    				}
    			}
    			
    		}
    	}
    
    }
    
    吃包子的人：
    import java.util.ArrayList;
    
    public class Person extends Thread{
        
    
    	//创建容器，用来存放包子
    	private ArrayList<String> list;
    
    	public Person(ArrayList<String> list) {
        
    		super();
    		this.list = list;
    	}
    	
    	@Override
    	public void run() {
        
    		
    		while (true) {
        
    			synchronized (list) {
        
    				//判断是否有包子
    				if (list.size() == 0) {
        
    					//没有包子，等待
    					try {
        
    						list.wait();
    					} catch (InterruptedException e) {
        
    						e.printStackTrace();
    					}
    				}else {
        
    					//有包子，吃包子
    					//吃包子时间
    					try {
        
    						Thread.sleep(1000);
    					} catch (InterruptedException e) {
        
    						e.printStackTrace();
    					}
    					System.out.println("包子吃完了");
    					//吃包子 (将集合清空)
    					list.clear();
    					//通过锁对象，唤醒线程，通知包子铺做包子
    					list.notify();
    				}
    			}
    			
    		}
    	}
    	
    }
    
    测试类
    import java.util.ArrayList;
    
    public class Test {
        
    	public static void main(String[] args) {
        
    		//创建集合对象
    		ArrayList<String> list = new ArrayList<String>();
    		
    		//开启线程
    		new BaoZi(list).start();
    		new Person(list).start();
    	}
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FfWmVuZ18_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/ca91ae9e55d64bdbbcd6f21a5a47cc59.png