首页 / JAVA / Java多线程学习——wait方法（管道法/生产者消费者模式）

Java多线程学习——wait方法（管道法/生产者消费者模式）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Java多线程学习——wait方法（管道法/生产者消费者模式），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1515字，纯文字阅读大概需要3分钟。

内容图文

简单介绍管道法：

生产者生产数据输送到管道，消费者从管道拿出数据，管道为空消费者等待，管道满生产者生产，消费者消费生产者生产，生产者生产消费者消费。

 

            public
            class Corn { //要生产的产品
}

 

            public
            class
             Buffer {
    
            private
            int count=0;    //产品计数器private Corn corn[]=new Corn[10];   //缓冲区容量，缓冲区满生产等待，缓冲区空消费者等待/*生产数据*/publicsynchronizedvoid produce(Corn corn){    //注意：wait()只能在同步块/同步方法中使用if(count>=this.corn.length){    //缓冲区满try {   //线程等待this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.corn[count]=corn;  //可以生产数据
        count++;
        this.notifyAll();   //通知消费    }
    /*取出数据*/publicsynchronized Corn getCorn(){
        if(count==0){   //缓冲区空try {   //线程等待this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        count--;    //可以取出数据this.notifyAll();   //通知生产return corn[count];
    }
}

 

            /**
            
 * 生产者类
 
            */
            public
            class Produce implements Runnable{
    private Buffer buffer;

    public Produce(Buffer buffer) {
        this.buffer = buffer;
    }

    @Override
    publicvoid run() {
        for (int i = 1; i <= 100; i++) {
            buffer.produce(new Corn());
            System.out.println("生产第"+i+"个产品");
        }
    }
}

 

            /**
            
 * 消费者类
 
            */
            public
            class Customer implements Runnable {
    private Buffer buffer;

    public Customer(Buffer buffer) {
        this.buffer = buffer;
    }

    @Override
    publicvoid run() {
        for (int i = 1; i <= 100; i++) {
            buffer.getCorn();
            System.out.println("得到第"+i+"份产品");
        }
    }
}

 

            /**
            
 * 主类
 
            */
            public
            class
             Test {
    
            public
            static
            void
             main(String[] args) {
        Buffer buffer=new Buffer();
        /*开启生产者和消费者进程*/new Thread(new Produce(buffer)).start();
        new Thread(new Customer(buffer)).start();
    }
}

 

原文：https://www.cnblogs.com/chiweiming/p/11161746.html

内容总结

以上是互联网集市为您收集整理的Java多线程学习——wait方法（管道法/生产者消费者模式）全部内容，希望文章能够帮你解决Java多线程学习——wait方法（管道法/生产者消费者模式）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1133529.html

来源：【匿名】