日期:2014-05-20 浏览次数:20795 次
package excise;
public class QueueTest {
public static void main(String[] args) {
QueueTest qt = new QueueTest();
try {
qt.add(9);
qt.add(10);
qt.add(8);
qt.add(1);
System.out.println(qt.poll());
qt.add(10249);
qt.add(40);
System.out.println(qt.poll());
System.out.println(qt.poll());
qt.add(66);
System.out.println(qt.poll());
} catch (Exception e) {
e.printStackTrace();
}
}
int head = 0;
int end = head;
int len = 5;
int cur = 0;
int[] arr = new int[len];
public void print() {
for (int i = 0; i < len; i++) {
System.out.print(arr[i] + ",");
}
System.out.println();
}
public void add(int ele) throws Exception {
if (cur >= 5) {
throw new Exception("full");
}
else {
arr[end] = ele;
cur++;
end++;
if (end >= len) {
end = 0;
}
}
print();
}
public int poll() throws Exception {
if (cur == 0) {
throw new Exception("empty");
}
int ret = arr[head];
head++;
if (head >= len) {
head = 0;
}
cur--;
print();
return ret;
}
}
package com.tur.iterator;
import java.util.Arrays;
import java.util.ConcurrentModificationException;
import java.util.Iterator;
import java.util.NoSuchElementException;
/**
* 循环队列。
* 在有的场景下非常有用,不停的接首传感器传来的数据,显示到界面上。
* 开辟一个容量为200的循环队列,用于保存新收到的200个传感器数据,
* 新接收到的数据覆盖前面的数据,需要显示的是最近新收到的数据,
* 比这200个还早的数据没有必要继续保存。
* 显示的GUI类遍历队列的数据绘制到界面上。
*
* ArrayBlockingQueue: 用循环数组实现的Queue
*
* for each 循环可以和任何实现了Iterable<E>接口的对象一起工作。
*/
public class CircularQueue<T> implements Iterable<T> {
private int head = 0;
private int size = 0;
private int capacity = 0;
private int modifiedCount = 0;
private T[] data = null;
/**
* 创建能够容纳16个元素的循环队列。
*/
public CircularQueue() {
this(16);
}
/**
* 创建能够容纳capacity个元素的循环队列。
* 如果capacity小于等于0,则capacity取1。
* @param capacity 队列的容量。
*/
public CircularQueue(int capacity) {
capacity = capacity > 0 ? capacity : 1;
this.capacity = capacity;
data = (T[]) new Object[capacity];
}
/**
* 在队尾加入一个元素。
* 如果当前队列的元素个数为其capacity,则新加入的元素放在原来的队首,队列的head后移动一个位置。
* @param element 要加入对尾的元素。
*/
public void enqueue(T element) {
int index = calculateIndex(size);
data[index] = element;
size++;
modifiedCount++;
if (size > capacity) {
size = capacity;