package com.hoho.datastruture.queue;import com.hoho.datastruture.array.Array;import java.util.Objects;import java.util.concurrent.ExecutorService;public class LoopQueue<E> implements Queue<E> { private E[] data; private int front; private int tail; private int size; public LoopQueue(int capacaty) { data = (E[]) new Object[capacaty - 1]; front = 0; tail = 0; size = 0; } public LoopQueue() { this(10); } @Override public void enqueue(E e) { if ((tail + 1) % data.length == front) { resize(getCapacity() * 2); } data[tail] = e; tail = (tail + 1) % data.length; size++; } private void resize(int newCapacity) { E[] newData = (E[]) new Object[newCapacity + 1]; for (int i = 0; i < size; i++) { //将原数组的队首元素放到新数组的索引为0的位置 newData[i] = data[(i + front) % data.length]; } data = newData; front = 0; tail = size; } @Override public E deque() { if (isEmpty()) { throw new IllegalArgumentException("empty queue!!!"); } E ret = data[front]; data[front] = null; front = (front + 1) % data.length; size--; if (size == getCapacity() / 4 && getCapacity() / 2 != 0) { resize(getCapacity() / 2); } return ret; } @Override public E getFront() { if (isEmpty()) { throw new IllegalArgumentException("empty queue!!!"); } return data[front]; } @Override public int getSize() { return size; } @Override public boolean isEmpty() { return front == tail; } public int getCapacity() { return data.length - 1; } @Override public String toString() { StringBuilder res = new StringBuilder(); res.append(String.format("Queue: size = %d, capacity = %d\n", size, getCapacity())); res.append("front ["); for (int i = front; i != tail; i = (i + 1) % data.length) { res.append(data[i]); if ((i + 1) % data.length != tail ) { res.append(", "); } } res.append("] tail"); return res.toString(); } public static void main(String[] args) { LoopQueue<Integer> queue = new LoopQueue<>(); for (int i = 0; i < 10; i++) { queue.enqueue(i); } System.out.println(queue); }}