zoukankan      html  css  js  c++  java
  • 多线程--生产者消费者--简单例子

    package com.lm.multest;
    
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    class Resource {
    	private int num;
    	private String name;
    	private boolean flag = false;
    	Lock lock = new ReentrantLock();
    	Condition notFull = lock.newCondition();
    	Condition notEmpty = lock.newCondition();
    
    	public void set(String n) {
    		lock.lock();
    		try {
    			while (flag)
    				notFull.await();
    			this.name = n + num++;
    			System.out.println(Thread.currentThread().getName() + "..生产..."
    					+ name);
    			flag = true;
    			notEmpty.signalAll();
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		} finally {
    			lock.unlock();
    		}
    
    	}
    
    	public void out() {
    		lock.lock();
    		try {
    			while (!flag)
    				notEmpty.await();
    			System.out.println(Thread.currentThread().getName() + "..消费.."
    					+ name);
    			flag = false;
    			notFull.signalAll();
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		} finally {
    			lock.unlock();
    		}
    
    	}
    }
    
    class Producer implements Runnable {
    
    	private Resource res;
    
    	Producer(Resource res) {
    		this.res = res;
    	}
    
    	@Override
    	public void run() {
    		while (true)
    			res.set("商品");
    	}
    
    }
    
    class Consumer implements Runnable {
    	private Resource res;
    
    	Consumer(Resource res) {
    		this.res = res;
    	}
    
    	public void run() {
    		while (true)
    			res.out();
    	}
    }
    
    public class ProducerConsumerDemo {
    
    	public static void main(String[] args) {
    		Resource r = new Resource();
    		Producer p = new Producer(r);
    		Consumer c = new Consumer(r);
    
    		Thread th1 = new Thread(p);
    		Thread th2 = new Thread(c);
    		Thread th3 = new Thread(p);
    		Thread th4 = new Thread(c);
    
    		th1.start();
    		th2.start();
    		th3.start();
    		th4.start();
    	}
    
    }
    


  • 相关阅读:
    win7 x64怎么枚举所有快捷键呢
    C/C++多种方法获取文件大小
    中缀表达式转后缀表达式(逆波兰表达式)
    检测文件存在的四种方法
    透明窗口与不规则窗口制作方法总结
    Struts 2命令执行漏洞
    Windows 8 无法安装
    从浏览器启动客户端程序
    tesseractocr训练方法
    Algorithm Gossip: 中序式轉後序式(前序式)
  • 原文地址:https://www.cnblogs.com/james1207/p/3285785.html
Copyright © 2011-2022 走看看