场景"/>
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"))
更多推荐
LinkedBlockingDeque应用场景
发布评论