-
Notifications
You must be signed in to change notification settings - Fork 160
/
BlockingQueueDemo.java
33 lines (29 loc) · 1.27 KB
/
BlockingQueueDemo.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
/*
* ArrayBlockingQueue:是一个基于数组结构的有界阻塞队列,此队列按FIFO原则对元素进行排序
* LinkedBlockingQueue:是一个基于链表结构的阻塞队列,此队列按FIFO排序元素,吞吐量高于ArrayBlockingQueue
* SynchronousQueue:一个不存储元素的阻塞队列,每个插入操作必须等到另一个线程调用移出操作,否则插入操作一直处于
* 阻塞状态,吞吐量通常要高
*
*
*
* 2.阻塞队列
* 2.1阻塞队列有没有好的一面
* 2.2不得不阻塞,你如何管理
* */
public class BlockingQueueDemo {
public static void main(String[] args) throws Exception{
// List list = null;
BlockingQueue<String> 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.element());
System.out.println(blockingQueue.remove());
System.out.println(blockingQueue.remove());
}
}