标签：BlockOne 队列 void 阻塞 private 生产者 new arrayBlockingQueue public

package queue;

import sun.awt.CustomCursor;

import java.util.concurrent.ArrayBlockingQueue;
// 初始生产者和消费者
public class BlockQuery {

    public static void main(String[] args) {
        BlockQuery blockQuery = new BlockQuery();

        BlockOne blockOne = blockQuery.new BlockOne();
        Customer customCursor = blockQuery.new Customer();
        blockOne.start();
        customCursor.start();

    }

    private int queryInt = 10;
    private ArrayBlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<Integer>(queryInt);

    // 使用内部类 简单制作
    class BlockOne extends Thread {
        @Override
        public void run() {
            BlockOne();
        }

        // 生产者
        private void BlockOne() {
            while (true) {
                try {
                    arrayBlockingQueue.put(1);
                    System.out.println("一直再生产，从未被放弃" + (queryInt - arrayBlockingQueue.size()));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        }
    }

    // 消费者简单
    class Customer extends Thread {
        @Override
        public void run() {
            customer();

        }

        private void customer() {
            while (true) {
                try {
                    arrayBlockingQueue.take();
                    System.out.println("来啊，一直在消费" + (arrayBlockingQueue.size()));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }

        }


    }


}

标签：BlockOne,队列,void,阻塞,private,生产者,new,arrayBlockingQueue,public
来源： https://www.cnblogs.com/limingming1993/p/15043315.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。