标签：poll 队列 System 阻塞 println ArrayBlockingQueue blockingQueue out

FIFO

BlockingQueue

• ArrayBlockingQueue
• LinkedBlockingQueue
• SynchronousQueue

什么时候使用阻塞队列

• 多线程并发处理，A调用B，如果B未执行完,A需要等待
• 多线程，线程池

使用队列

四组API

1. 抛出异常
2. 不会抛出异常
3. 阻塞等待
4. 超时等待

//List BlockingQueue Set
public class Test {
    public static void main(String[] args) throws InterruptedException {
        test4();
    }
    /*
    * 抛出异常
    *
    * Exception in thread "main" java.lang.IllegalStateException: Queue full
	    at java.util.AbstractQueue.add(AbstractQueue.java:98)
	    at java.util.concurrent.ArrayBlockingQueue.add(ArrayBlockingQueue.java:312)
	    at com.ji.BlockingQueue.Test.test1(Test.java:20)
	    at com.ji.BlockingQueue.Test.main(Test.java:9)
    * */
    public static void test1(){
        //队列的大小
        ArrayBlockingQueue 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.remove());
         /*System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());
        System.out.println(blockingQueue.remove());*/
        System.out.println(blockingQueue.element());
    }
    /*
       * 不抛出异常有返回值 false
       *
       * */
    public static void test2() {
        //队列的大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        System.out.println(blockingQueue.offer("a"));
        System.out.println(blockingQueue.offer("b"));
        System.out.println(blockingQueue.offer("c"));
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.poll());
        System.out.println(blockingQueue.peek());

    }
    /*
     * 阻塞等待（一直阻塞）
     *
     * */
    public static void test3() throws InterruptedException {
        //队列的大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        blockingQueue.put("a");
        blockingQueue.put("b");
        blockingQueue.put("c");
        //blockingQueue.put("d");  //队列没有位置时会一直等待
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
        System.out.println(blockingQueue.take());
        //System.out.println(blockingQueue.take());  // //队列没有元素时会一直等待


    }

    /*
     * 阻塞等待（等待超时）
     *
     * */
    public static void test4() throws InterruptedException {
        //队列的大小
        ArrayBlockingQueue blockingQueue = new ArrayBlockingQueue<>(3);
        System.out.println(blockingQueue.offer("a", 2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.offer("b", 2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.offer("c", 2, TimeUnit.SECONDS));
        //System.out.println(blockingQueue.offer("d", 2, TimeUnit.SECONDS));//等待超过两秒就退出
        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));
        System.out.println(blockingQueue.poll(2, TimeUnit.SECONDS));


    }
}

标签：poll,队列,System,阻塞,println,ArrayBlockingQueue,blockingQueue,out
来源： https://www.cnblogs.com/Liuyunsan/p/15803018.html

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