新年
快乐
最新公告
  • 欢迎您光临码巴巴,本站秉承服务宗旨 履行“站长”责任,销售只是起点 服务永无止境!立即加入我们
  • 多线程-线程通讯之-管程法(生产者-消费者-缓存区)

     

    package com.demo3;
    
     
    import java.util.Vector;
    
    /**
     * 管程法
     * 
     * 1.生产者--生产phone
     * 2.消费者--消费phone
     * 3.产品:phone
     * 4.缓存区
     * 		4.1 当生产者手机生产出来 -- 通知消费者
     * 	    4.2 当消费者消费完手机--通知生产者生产
     *      4.3 当消费者消费完成手机,需要等待生产者生产数据后再进行消费
     *      4.4 当生产者生产的手机未被消费,则需要等待消费者消费后继续生产 
     *
     */
    
    public class PCtest {
        
                public static void main(String[] args) {
                            
                    Buffer buffer = new Buffer();
    
                    Producer producer = new Producer(buffer);
                    Consumer consumer = new Consumer(buffer);
                    
                    
                    new Thread(producer).start();
                    new Thread(consumer).start();
                    
                    
                }
    }
    
    
    /**
     * 手机--产品
     * @author MSI-NB
     *
     */
    class Phone{
        private int id;
    
        public int getId() {
            return id;
        }
    
        public void setId(int id) {
            this.id = id;
        }
    
        public Phone(int id) {
            this.id = id;
        }
        
         
         
    }
    
    
    
    /**
     * 生产者
     */
    class Producer implements   Runnable  {
        private Buffer buffer;
         
        private Phone phone;
        
        
        public Phone getPhone() {
            return phone;
        }
    
    
        public void setPhone(Phone phone) {
            this.phone = phone;
        } 
        public Buffer getBuffer() {
            return buffer;
        }
    
    
        public void setBuffer(Buffer buffer) {
            this.buffer = buffer;
        } 
        public Producer(Buffer buffer) {
            this.buffer = buffer;
             
        }
    
    
        @Override
        public void run() {  
            for(int i=0; i<100; i++ ) {
                
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            
                
                buffer.push(new Phone(i));
                System.out.println("生产了第"  + i + "个手机");
            } 
        } 
    }
    
    /**
     *  消费者
     */
    class Consumer implements   Runnable  { 
        
        
        @Override
        public void run() {
            for(int i =0; i<100;i++) {
                
     
                
                
                getBuffer().pop();
                System.out.println("消费了第" + i  + "个手机");
            } 
        }
        
        
        
        private Buffer buffer;
        
        
        public Buffer getBuffer() {
            return buffer;
        }
    
    
        public void setBuffer(Buffer buffer) {
            this.buffer = buffer;
        }
    
    
        public Consumer(Buffer buffer) {
            this.buffer = buffer;
        }
    
    
        
    
        
        
        
    }
    
    
    
    /**
     * 缓存区
     */
    class Buffer    {
        
        
        private Vector<Phone>   phones = new Vector<Phone>();
        
     
        public Vector<Phone> getPhones() {
            return phones;
        }
    
        public void setPhones(Vector<Phone> phones) {
            this.phones = phones;
        }
        
        
        /**
         * 生产
         */
        public synchronized void push(Phone   phones) {
            
            /**
             * 当生产者生产的手机未被消费,则需要等待消费者消费后继续生产 
             */ 
            if( getPhones().size()  ==100) {
                try {
                    this.wait();
                    
                    System.out.println("生产者等待");
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }   
            getPhones().add(phones);
            this.notifyAll();
            
        }
        
        /**
         * 消费
         */
        public  synchronized void pop() {
            //当消费者消费完成手机,需要等待生产者生产数据后再进行消费
            if( getPhones().size()  == 0) {
                try {
                    this.wait();
                    
                    System.out.println("消费者等待"); 
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                
            } 
            
            
            int nums = getPhones().size();
            getPhones().remove(--nums);
            this.notifyAll();
        }
        
    
     
        
        
    }
    
    

     

     

    1. 本站所有资源来源于用户上传和网络,如有侵权请及时联系站长!

    2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!

    3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!

    4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!

    5. 如有链接无法下载、失效或广告,请联系管理员处理!

    6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需!

    7. 如遇到加密压缩包,默认解压密码为"mababa.xin",如遇到无法解压的请联系管理员!


    码巴巴-优质代码创造者 » 多线程-线程通讯之-管程法(生产者-消费者-缓存区)

    常见问题FAQ

    免费下载或者VIP会员专享资源能否直接商用?
    本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用者承担。更多说明请参考 VIP介绍。
    提示下载完但解压或打开不了?
    最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度网盘软件或迅雷下载。若排除这种情况,可在对应资源底部留言,或 联络我们.。
    找不到素材资源介绍文章里的示例图片?
    对于PPT,KEY,Mockups,APP,网页模版等类型的素材,文章内用于介绍的图片通常并不包含在对应可供下载素材包内。这些相关商业图片需另外购买,且本站不负责(也没有办法)找到出处。 同样地一些字体文件也是这种情况,但部分素材会在素材包内有一份字体下载链接清单。
    一个高级程序员模板开发平台
    问问管理员?

    发表评论

    • 13会员总数(位)
    • 37资源总数(个)
    • 0本周发布(个)
    • 0 今日发布(个)
    • 573稳定运行(天)

    提供最优质的资源集合

    立即查看 了解详情
    升级SVIP尊享更多特权立即升级