JUC01阻塞队列(BlockingQueue)

 1 package com.jenne.mydemo;
 2 
 3 import org.junit.jupiter.api.Test;
 4 
 5 import java.util.concurrent.ArrayBlockingQueue;
 6 import java.util.concurrent.BlockingQueue;
 7 import java.util.concurrent.TimeUnit;
 8 
 9 /*
10     ArrayBlockingQueue：     由数组结构组成的有界阻塞队列。*
11     LinkedBlockingQueue：    由链表结构组成的有界（但大小默认值为integer.MAX_VALUE）阻塞队列。*
12     PriorityBlockingQueue：  支持优先级排序的无界阻塞队列。
13     DelayQueue：             使用优先级队列实现的延迟无界阻塞队列。
14     SynchronousQueue：       不存储元素的阻塞队列，也即单个元素的队列。*
15     LinkedTransferQueue：    由链表组成的无界阻塞队列。
16     LinkedBlockingDeque：    由链表组成的双向阻塞队列。
17 */
18 public class TestBlockingQueue {
19     @Test
20     public void testArrayBlockingQueue01() {
21         //创建一个ArrayBlockingQueue具有给定（固定）容量
22         ArrayBlockingQueue abq = new ArrayBlockingQueue(3);
23 
24         System.out.println(abq.add("a"));
25         System.out.println(abq.add("b"));
26         System.out.println(abq.add("c"));
27         //System.out.println(abq.add("d"));//出现 java.lang.IllegalStateException: Queue full 异常
28 
29         System.out.println(abq.remove());
30         System.out.println(abq.remove());
31         System.out.println(abq.remove());
32         //System.out.println(abq.remove());//出现 java.util.NoSuchElementException 异常
33     }
34 
35     @Test
36     public void testArrayBlockingQueue02() {
37         //创建一个ArrayBlockingQueue具有给定（固定）容量
38         ArrayBlockingQueue abq = new ArrayBlockingQueue(3);
39 
40         System.out.println(abq.offer("a"));
41         System.out.println(abq.offer("b"));
42         System.out.println(abq.offer("c"));
43         //System.out.println(abq.offer("d"));//超过了给定容量，返回false
44 
45         System.out.println(abq.poll());
46         System.out.println(abq.poll());
47         System.out.println(abq.poll());
48         //System.out.println(abq.poll());//超过了给定容量，返回null
49     }
50 
51     @Test
52     public void testArrayBlockingQueue03() throws InterruptedException {
53         //创建一个ArrayBlockingQueue具有给定（固定）容量
54         BlockingQueue abq = new ArrayBlockingQueue(3);
55 
56         abq.put("a");
57         abq.put("b");
58         abq.put("c");
59         //abq.put("x");//使程序一直阻塞，无法停止
60         System.out.println(abq.take());
61         System.out.println(abq.take());
62         System.out.println(abq.take());
63         //System.out.println(abq.take());//使程序一直阻塞，无法停止
64     }
65 
66     @Test
67     public void testArrayBlockingQueue04() throws InterruptedException {
68         //创建一个ArrayBlockingQueue具有给定（固定）容量
69         BlockingQueue abq = new ArrayBlockingQueue(3);
70 
71         System.out.println(abq.offer("a"));
72         System.out.println(abq.offer("b"));
73         System.out.println(abq.offer("c"));
74         //System.out.println(abq.offer("d"));//超过了给定容量，返回false
75 
76         System.out.println(abq.poll());
77         System.out.println(abq.poll());
78         System.out.println(abq.poll());
79         //System.out.println(abq.poll(4, TimeUnit.SECONDS));//4s后获取数据，但是超过了给定容量，返回null
80     }
81 }