-
Notifications
You must be signed in to change notification settings - Fork 0
/
RandomizedQueue.java
235 lines (204 loc) · 4.99 KB
/
RandomizedQueue.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
* RandomizedQueue creates a random queue of iterable items.
*
* @author manyanair insanorcross
* @version Summer 2022
*/
package a02;
import java.util.Iterator;
import java.util.NoSuchElementException;
import edu.princeton.cs.algs4.StdOut;
import edu.princeton.cs.algs4.StdRandom;
public class RandomizedQueue<Item> implements Iterable<Item>
{
private Item[] queue;
private int size;
@SuppressWarnings("unchecked")
public RandomizedQueue()
{
queue = (Item[]) new Object[1];
size = 0;
}
/**
* Checks the size to see if the queue is empty
*
* @return if the queue is empty or not
*/
public boolean isEmpty()
{
return (size == 0);
}
/**
* Returns the number of items in the queue.
*
* @return size of queue
*/
public int size()
{
return size;
}
/**
* Changes the number of total slots in the queue to 'capacity.'
*
* @param capacity - number of total slots in new queue
*/
private void resize(int capacity)
{
@SuppressWarnings("unchecked")
Item[] temp = (Item[]) new Object[capacity];
for (int i = 0; i < size; i++)
{
temp[i] = queue[i];
}
queue = temp;
}
/**
* Adds item to the queue.
*
* @param item - to be added to queue
*/
public void enqueue(Item item)
{
// Handle edge case
if (item == null)
throw new NullPointerException("The entry is null");
// Double queue if full
if (size == queue.length)
{
resize(2 * queue.length);
}
// Add item to queue
queue[size++] = item;
}
/**
* Randomly selects an item from the queue to be removed.
*
* @return item - that was removed
*/
public Item dequeue()
{
// Handle edge case
if (isEmpty())
throw new NoSuchElementException("The queue is empty");
// Randomly remove an item in queue
// and move last item into vacant spot
int randomInt = StdRandom.uniform(0, size);
Item item = queue[randomInt];
size--;
queue[randomInt] = queue[size];
queue[size] = null; // Avoid loitering
// Decrease queue size if 1/4 full
if (size <= queue.length / 4)//queue.length > 4 &&
{
resize(queue.length / 2);
}
return item;
}
/**
* Randomly returns an item from the queue,
* but does not remove it from the queue.
*
* @return item - randomly chosen from queue
*/
public Item sample()
{
if (isEmpty())
throw new NoSuchElementException("The queue is empty");
return queue[StdRandom.uniform(0, size)];
}
/**
* Creates new Iterator
*/
public Iterator<Item> iterator()
{
return new QueueIterator(queue, size);
}
/**
* Implements classes for Iterator interface
* by randomly iterating through the queue.
*/
private class QueueIterator implements Iterator<Item>
{
private Item[] iteratorQueue;
private int iteratorIndex = 0;
@SuppressWarnings("unchecked")
public QueueIterator(Item[] queue, int size)
{
iteratorQueue = (Item[]) new Object[size];
// Copy queue into private interatorQueue
for (int i = 0; i < iteratorQueue.length; i++)
{
iteratorQueue[i] = queue[i];
}
// Randomize copied queue so that the iteration is random
for (int j = 1; j < iteratorQueue.length; j++)
{
int swapIndex = StdRandom.uniform(j + 1);
Item temp = iteratorQueue[j];
iteratorQueue[j] = iteratorQueue[swapIndex];
iteratorQueue[swapIndex] = temp;
}
}
@Override
public boolean hasNext()
{
return (iteratorIndex < iteratorQueue.length);
}
public void remove()
{
throw new UnsupportedOperationException();
}
@Override
public Item next()
{
if (!hasNext())
{
throw new NoSuchElementException("Queue is empty");
}
Item item = iteratorQueue[iteratorIndex];
iteratorIndex++;
return item;
}
}
// Testing RandomizedQueue:
public static void main(String[] args)
{
// Test if queue is empty after adding one item and removing it
RandomizedQueue<Integer> randomQ1 = new RandomizedQueue<Integer>();
randomQ1.enqueue(1);
for (int r : randomQ1)
{
StdOut.print(r);
}
StdOut.println();
randomQ1.dequeue();
for (int r : randomQ1)
{
StdOut.print(r);
}
StdOut.println();
StdOut.println(randomQ1.size());
StdOut.println(randomQ1.isEmpty());
StdOut.println();
// Test if output is random
RandomizedQueue<Integer> randomQ2 = new RandomizedQueue<Integer>();
for (int i = 0; i < 10; i++)
{
randomQ2.enqueue(i);
}
for (Integer j : randomQ2)
{
StdOut.print(j + " ");
}
StdOut.println();
// Test if all items get removed
for (int j = 0; j < 10; j++)
{
int test = (int) randomQ2.dequeue();
StdOut.print(test + " ");
}
StdOut.println();
StdOut.println(randomQ2.size());
StdOut.println(randomQ2.isEmpty());
StdOut.println();
}
}