J2SE——线程（生产者与消费者）

- 日理万妓 2022-05-31 13:20 181阅读 0赞

一、线程简析

1、概念

线程是一个程序内部的顺序控制流，简单点说就是一个程序里面不同的执行路径。

特别的：main方法也是个线程，是主线程。

2、创建

java的线程是通过java.lang.Thread类来实现的，可以通过创建Thread的实例来创建新的线程。

每个线程都是通过某个特定Thread对象所对应的方法run（）来完成其操作的，方法run为线程体。

3、启动

线程启动必须调用Thread类的start（）方法，start（）方法会通知CPU线程准备好了

3、控制

（1）、线程控制基本方法

![20180227211442645][]

（2）、sleep（）和wait（）的区别：

①相同点：

都可以让自己的睡眠停一小会

②不同点：

sleep（）：是Thread类的方法，sleep时别的线程不可以访问锁定对象（相当于睡着的时候也抱着锁不让别人动）

wait（）：是Object类的方法，wait时别的线程可以访问锁定对象，（相当于wait时把这把锁放开了）

4、同步

同步是多线程中的重要概念。同步的使用可以保证在多线程运行的环境中，程序不会产生设计之外的错误结果。同步的实现方式有两种，同步方法和同步块，这两种方式都要用到synchronized关键字。

同步方法:给一个方法增加synchronized修饰符之后就可以使它成为同步方法，这个方法可以是静态方法和非静态方法，但是不能是抽象类的抽象方法，也不能是接口中的接口方法。

二、实例：生产者与消费者

1、代码

//生产者与消费者：一个往框里放窝头一个往外拿窝头
    public class ProducerConsumer{
    	public static void main(String[] args){
    		//new一个框出来
    		SyncStack ss=new SyncStack();
    		//生产者和消费者访问同一个框
    		Producer p=new Producer(ss);
    		Consumer c=new Consumer(ss);
    		
    		//new线程，然后启动线程
    		new Thread(p).start();
    		new Thread(c).start();
    	}
    }
    
    
    //窝头类
    class WoTou{
    	//编号
    	int id;
    	//构造方法
    	WoTou(int id){
    		this.id=id;
    	}
    	
    	public String toString(){
    		return "WoTou:" + id;
    	}
    }
    
    //框类：用栈代替
    class SyncStack{
    	//装到第几个了
    	int index=0;
    	//窝头数组
    	WoTou[] arrWT=new WoTou[6];
    	
    	//放:用synchronized锁定push方法，可以防止被其他线程中断
    	public synchronized void push(WoTou wt){
    		//如果篮子满了先等等
    	    if(index == arrWT.length){
    			try{
    				//Object里面的wait方法，任何一个对象都可以调用它， 正在访问的线程
    		        this.wait();
    			}catch(InterruptedException e){
    				e.printStackTrace();
    			}
    	    }
    		//叫醒线程
    		this.notify();
    		//等于新传进来的窝头
    		arrWT[index]=wt;
    		index ++;
    	}
    	
    	//拿:也用用synchronized锁定，可以防止被其他线程中断
    	public synchronized WoTou pop(){
    		//如果篮子空了也先等等
    		if(index==0){
    			try{
    				//Object里面的wait方法，任何一个对象都可以调用它， 正在访问的线程
    		        this.wait();
    			}catch(InterruptedException e){
    				e.printStackTrace();
    			}
    		}
    		//叫醒线程
    		this.notify();
    		index--;
    		return arrWT[index];
    	}
    }
    
    //生产者类
    class Producer implements Runnable{
    	SyncStack ss=null;
    	//构造方法
    	Producer(SyncStack ss){
    		this.ss=ss;
    	}
    	
    	public void run(){
    		for(int i=0;i<20;i++){
    			//把窝头传进去
    			WoTou wt=new WoTou(i);
    			ss.push(wt);
    			System.out.println("Produce :"+wt);
    			try{
    				//每生产一个睡眠一秒钟
    				Thread.sleep(1000);
    			}catch(InterruptedException e){
    				e.printStackTrace();
    			}
    		}
    	}
    }
    
    
    //消费者类
    class Consumer implements Runnable{
    	SyncStack ss=null;
    	//构造方法
    	Consumer(SyncStack ss){
    		this.ss=ss;
    	}
    	
    	public void run(){
    		for(int i=0;i<20;i++){
    			//把窝头传进去
    			WoTou wt=ss.pop();
    			System.out.println("Consum :"+wt);
    			try{
    				//消费一个睡眠一秒钟
    				Thread.sleep(1000);
    			}catch(InterruptedException e){
    				e.printStackTrace();
    			}
    		}
    	}
    }

2、效果图

![Center][]

[20180227211442645]: /images/20220531/f95e5c848da7441489c32b88d970ad89.png
[Center]: /images/20220531/bcd8006a210f4003bf70140f9493db47.png