LinkedBlockingDeque应用场景

场景"/>

LinkedBlockingDeque应用场景

BlockingDeque是多线程双头队列接口，LinkedBlockingDeque是其一种实现。

Deque的特点是可以同时在队列的两头put、take元素。

在TCP协议中，数据报有一个URG指针。正常情况下，接收者按数据包到达本机的顺序处理，而对于设置URG标志的数据报则会优先处理。

本文用BlockingDeque模拟TCP的单工通道。正确情况下发送者按顺序将数据追加到Deque的左边，当发生紧急情况时，发送者将数据追加到Deque的右边。接收者总是从队列的右边读取数据。

代码：

package com.zhangdb.thread;import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.atomic.AtomicInteger;class DataItem {private final int number;private final boolean flag;protected static final AtomicInteger count = new AtomicInteger(0);public DataItem(int number) {this.number = number;if ((number % 3) == 0) {flag = true;} else {flag = false;}count.incrementAndGet();}public void show() {System.out.println(number + ": " + ((flag == true) ? "Urgency" : "Common"))