ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

java-JUC--BlockingQueueDemo(阻塞队列)

2021-06-07 22:04:40  阅读:210  来源: 互联网

标签:JUC BlockingQueueDemo java offer System add println out blockingQueue


  1. 例子:BlockQueueDemo
  2. 栈和队列
  3. 阻塞队列
    1.  

       

       

       

       

        
  4. 阻塞队列的好处
    1.  

       

       

       
  5. 架构梳理和种类分析
    1.  
    2.  

       

       

       

       

       

       

       
  6. BlockQueue核心方法
    1.  

       

        
  7. 代码
    1. package com.model.queue;
      
      import jdk.nashorn.internal.ir.Block;
      
      import java.util.concurrent.ArrayBlockingQueue;
      import java.util.concurrent.BlockingQueue;
      import java.util.concurrent.TimeUnit;
      
      /**
       * @Description:测试类
       * @Author: 张紫韩
       * @Crete 2021/6/7 21:27
       */
      public class BlockingQueueDemo {
          public static void main(String[] args) throws InterruptedException {
              //阻塞队列
              BlockingQueue blockingQueue=new ArrayBlockingQueue(3);
      /*        System.out.println(blockingQueue.add("a"));
              System.out.println(blockingQueue.add("b"));
              System.out.println(blockingQueue.add("c"));
      //        System.out.println(blockingQueue.add("x"));
      
              System.out.println(blockingQueue.remove());
              System.out.println(blockingQueue.remove());
              System.out.println(blockingQueue.remove());
      //        System.out.println(blockingQueue.remove());*/
      
           /*   System.out.println(blockingQueue.add("a"));
              System.out.println(blockingQueue.add("b"));
              System.out.println(blockingQueue.element());*/
      
      /*
              System.out.println(blockingQueue.offer("a"));
              System.out.println(blockingQueue.offer("c"));
              System.out.println(blockingQueue.offer("d"));
              System.out.println(blockingQueue.offer("f"));
              System.out.println(blockingQueue.poll());
              System.out.println(blockingQueue.poll());
              System.out.println(blockingQueue.poll());
              System.out.println(blockingQueue.poll());*/
      
          /*    //如果满了会一直等待阻塞
              blockingQueue.put("a");
              blockingQueue.put("a");
              blockingQueue.put("a");
      //        blockingQueue.put("a");
      
              //如果资源不够了就一直等待阻塞,知道有资源后在执行
              System.out.println(blockingQueue.take());
              System.out.println(blockingQueue.take());
              System.out.println(blockingQueue.take());
              System.out.println(blockingQueue.take());
      */
      //        等待资源,等待时间为3秒,3秒没有等到,就会部等待,去寻找其他 的资源
              System.out.println(blockingQueue.offer("a",3,TimeUnit.SECONDS));
      
          }
      }

       

        

标签:JUC,BlockingQueueDemo,java,offer,System,add,println,out,blockingQueue
来源: https://www.cnblogs.com/zzhAylm/p/14857525.html

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

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有