java测试线程同步synchronized，生产者消费者模型wait、notify、notifyAll

秒速五厘米 2022-04-06 09:58 161阅读 0赞

# java测试线程同步synchronized，生产者消费者模型wait、notify、notifyAll #

java测试线程同步synchronized

TT.java

public class TT implements Runnable {
    	int b = 100;
    	
    	public synchronized void m1() throws Exception{
    		//Thread.sleep(2000);
    		b = 1000;
    		Thread.sleep(5000);
    		System.out.println("b = " + b);
    	}
    	
    	public synchronized void m2() throws Exception {
    		Thread.sleep(2500);
    		b = 2000;
    	}
    	
    	public void run() {
    		try {
    			m1();
    		} catch(Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    	public static void main(String[] args) throws Exception {
    		TT tt = new TT();
    		Thread t = new Thread(tt);
    		t.start();
    		//t.sleep(500);
    		tt.m2();
    		System.out.println(tt.b);
    	}
    }

F:\java\Thread>javac TT.java
    
    F:\java\Thread>java TT
    1000
    b = 1000
    
    F:\java\Thread>

生产者消费者模型wait、notify、notifyAll

/*
    	生产者消费者模型
    */
    public class ProducerConsumer {
    	public static void main(String[] args) {
    		//一个篮子
    		SyncStack ss = new SyncStack();
    		//生产者
    		Producer p = new Producer(ss);
    		//消费者
    		Consumer c = new Consumer(ss);
    		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;
    	//一个篮子放6个数组的窝头
    	WoTou[] arrWT = new WoTou[6];
    	
    	//放
    	public synchronized void push(WoTou wt) {
    		while(index == arrWT.length) {
    			try {
    				this.wait();
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    		this.notifyAll();		
    		arrWT[index] = wt;
    		index ++;
    	}
    	
    	//拿
    	public synchronized WoTou pop() {
    		while(index == 0) {
    			try {
    				this.wait();
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    		this.notifyAll();
    		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("生产了：" + wt);
    			try {
    				Thread.sleep((int)(Math.random() * 200));
    			} 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("消费了: " + wt);
    			try {
    				Thread.sleep((int)(Math.random() * 1000));
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}			
    		}
    	}
    }

F:\java\Thread>javac ProducerConsumer.java
    
    F:\java\Thread>java ProducerConsumer
    生产了：WoTou : 0
    消费了: WoTou : 0
    生产了：WoTou : 1
    生产了：WoTou : 2
    生产了：WoTou : 3
    生产了：WoTou : 4
    生产了：WoTou : 5
    生产了：WoTou : 6
    消费了: WoTou : 6
    生产了：WoTou : 7
    消费了: WoTou : 7
    生产了：WoTou : 8
    消费了: WoTou : 8
    生产了：WoTou : 9
    消费了: WoTou : 9
    生产了：WoTou : 10
    消费了: WoTou : 10
    生产了：WoTou : 11
    消费了: WoTou : 11
    生产了：WoTou : 12
    消费了: WoTou : 12
    生产了：WoTou : 13
    消费了: WoTou : 13
    生产了：WoTou : 14
    消费了: WoTou : 14
    生产了：WoTou : 15
    生产了：WoTou : 16
    消费了: WoTou : 15
    消费了: WoTou : 16
    生产了：WoTou : 17
    生产了：WoTou : 18
    消费了: WoTou : 17
    消费了: WoTou : 18
    生产了：WoTou : 19
    消费了: WoTou : 19
    消费了: WoTou : 5
    消费了: WoTou : 4
    消费了: WoTou : 3
    消费了: WoTou : 2
    消费了: WoTou : 1
    
    F:\java\Thread>