摘要：循環(huán)隊(duì)列，用于保存最新的幾個(gè)值在做一個(gè)監(jiān)控，用于保存最新的監(jiān)控?cái)?shù)據(jù)，需要一個(gè)集合存放監(jiān)控?cái)?shù)據(jù)，當(dāng)集合滿的時(shí)候，新的監(jiān)控?cái)?shù)據(jù)需要把舊的監(jiān)控給沖掉，只保存最新的監(jiān)控?cái)?shù)據(jù)。
循環(huán)隊(duì)列，用于保存最新的幾個(gè)值
在做一個(gè)監(jiān)控，用于保存最新的監(jiān)控?cái)?shù)據(jù)，需要一個(gè)集合存放監(jiān)控?cái)?shù)據(jù)，當(dāng)集合滿的時(shí)候，新的監(jiān)控?cái)?shù)據(jù)需要把舊的監(jiān)控給沖掉，只保存最新的監(jiān)控?cái)?shù)據(jù)。下面是一個(gè)簡(jiǎn)單的實(shí)現(xiàn)
import java.io.Serializable;
/**
* 基于數(shù)據(jù)實(shí)現(xiàn)的循環(huán)隊(duì)列，用于存取最新的固定長(zhǎng)度的數(shù)據(jù)
*
* @author WangJun
* @version 1.0 15/9/16
* @since 1.6
*/
public class CycleQueue implements Serializable {
/**
* 數(shù)組下一個(gè)索引位置
*/
private int index;
/**
* 循環(huán)隊(duì)列的大小
*/
private int length;
/**
* 是否隊(duì)列已處于循環(huán)轉(zhuǎn)態(tài)
*/
private boolean cycle;
/**
* 存取具體數(shù)據(jù)的容器
*/
private Object[] data;
/**
* 利用指定大小的值初始化循環(huán)隊(duì)列容器
*
* @param length
*/
public CycleQueue(int length) {
this.length = length;
data = new Object[length];
}
/**
* 線程安全的存入最新值到容器中
*
* @param value
*/
public synchronized void push(E value) {
if (index >= length) {
index = index - length;
cycle = true;
}
data[index] = value;
index++;
}
/**
* 獲取目前容器內(nèi)的所有值
* 注意當(dāng)集合未滿時(shí)，未存放值得地方會(huì)返回null
*
* @return
*/
public Object[] get() {
Object[] truthData = new Object[length];
int currentIndex = (index - 1);
if (cycle) {
for (int i = (length - 1); i >= 0; i--) {
if (currentIndex < 0) {
truthData[i] = data[currentIndex + length];
} else {
truthData[i] = data[currentIndex];
}
currentIndex--;
}
} else {
return data;
}
return truthData;
}
/**
* 獲取容器內(nèi)的最新值
*
* @return the latest value
*/
public E getCurrentValue() {
int currentIndex = (index - 1);
if (currentIndex < 0) currentIndex = 0;
return (E) data[currentIndex];
}
@Override
public String toString() {
Object[] data = get();
String res = "[ ";
for (Object object : data) {
res += object + ",";
}
res = res.substring(0, res.length() - 1);
res += " ]";
return res;
}
}
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/64651.html
