ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicIntegerArrayTest.java
Revision: 1.30
Committed: Wed Dec 31 19:21:20 2014 UTC (9 years, 4 months ago) by jsr166
Branch: MAIN
Changes since 1.29: +3 -3 lines
Log Message:
prefer do {} while (...); to while (...);

File Contents

# User Rev Content
1 dl 1.1 /*
2 dl 1.6 * Written by Doug Lea with assistance from members of JCP JSR-166
3     * Expert Group and released to the public domain, as explained at
4 jsr166 1.20 * http://creativecommons.org/publicdomain/zero/1.0/
5 jsr166 1.11 * Other contributors include Andrew Wright, Jeffrey Hayes,
6     * Pat Fisher, Mike Judd.
7 dl 1.1 */
8    
9 jsr166 1.22 import java.util.Arrays;
10     import java.util.concurrent.atomic.AtomicIntegerArray;
11 dl 1.1
12 jsr166 1.29 import junit.framework.Test;
13     import junit.framework.TestSuite;
14    
15 dl 1.3 public class AtomicIntegerArrayTest extends JSR166TestCase {
16 dl 1.1
17 jsr166 1.17 public static void main(String[] args) {
18     junit.textui.TestRunner.run(suite());
19 dl 1.1 }
20     public static Test suite() {
21     return new TestSuite(AtomicIntegerArrayTest.class);
22     }
23    
24 dl 1.4 /**
25 dl 1.5 * constructor creates array of given size with all elements zero
26 dl 1.4 */
27     public void testConstructor() {
28 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
29     for (int i = 0; i < SIZE; i++)
30     assertEquals(0, aa.get(i));
31 dl 1.1 }
32    
33 dl 1.4 /**
34 dl 1.7 * constructor with null array throws NPE
35     */
36     public void testConstructor2NPE() {
37     try {
38     int[] a = null;
39 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(a);
40 jsr166 1.14 shouldThrow();
41     } catch (NullPointerException success) {}
42 dl 1.7 }
43    
44     /**
45     * constructor with array is of same size and has all elements
46     */
47     public void testConstructor2() {
48 jsr166 1.23 int[] a = { 17, 3, -42, 99, -7 };
49 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(a);
50     assertEquals(a.length, aa.length());
51     for (int i = 0; i < a.length; i++)
52     assertEquals(a[i], aa.get(i));
53 dl 1.7 }
54    
55     /**
56 dl 1.5 * get and set for out of bound indices throw IndexOutOfBoundsException
57     */
58 jsr166 1.13 public void testIndexing() {
59 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
60     for (int index : new int[] { -1, SIZE }) {
61     try {
62     aa.get(index);
63     shouldThrow();
64     } catch (IndexOutOfBoundsException success) {}
65     try {
66     aa.set(index, 1);
67     shouldThrow();
68     } catch (IndexOutOfBoundsException success) {}
69     try {
70     aa.lazySet(index, 1);
71     shouldThrow();
72     } catch (IndexOutOfBoundsException success) {}
73     try {
74     aa.compareAndSet(index, 1, 2);
75     shouldThrow();
76     } catch (IndexOutOfBoundsException success) {}
77     try {
78     aa.weakCompareAndSet(index, 1, 2);
79     shouldThrow();
80     } catch (IndexOutOfBoundsException success) {}
81     try {
82     aa.getAndAdd(index, 1);
83     shouldThrow();
84     } catch (IndexOutOfBoundsException success) {}
85     try {
86     aa.addAndGet(index, 1);
87     shouldThrow();
88     } catch (IndexOutOfBoundsException success) {}
89 dl 1.5 }
90     }
91    
92     /**
93     * get returns the last value set at index
94 dl 1.4 */
95     public void testGetSet() {
96 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
97     for (int i = 0; i < SIZE; i++) {
98     aa.set(i, 1);
99     assertEquals(1, aa.get(i));
100     aa.set(i, 2);
101     assertEquals(2, aa.get(i));
102     aa.set(i, -3);
103     assertEquals(-3, aa.get(i));
104 dl 1.1 }
105     }
106    
107 dl 1.4 /**
108 dl 1.10 * get returns the last value lazySet at index by same thread
109     */
110     public void testGetLazySet() {
111 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
112     for (int i = 0; i < SIZE; i++) {
113     aa.lazySet(i, 1);
114     assertEquals(1, aa.get(i));
115     aa.lazySet(i, 2);
116     assertEquals(2, aa.get(i));
117     aa.lazySet(i, -3);
118     assertEquals(-3, aa.get(i));
119 dl 1.10 }
120     }
121    
122     /**
123 dl 1.5 * compareAndSet succeeds in changing value if equal to expected else fails
124 dl 1.4 */
125     public void testCompareAndSet() {
126 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
127     for (int i = 0; i < SIZE; i++) {
128     aa.set(i, 1);
129     assertTrue(aa.compareAndSet(i, 1, 2));
130     assertTrue(aa.compareAndSet(i, 2, -4));
131     assertEquals(-4, aa.get(i));
132     assertFalse(aa.compareAndSet(i, -5, 7));
133     assertEquals(-4, aa.get(i));
134     assertTrue(aa.compareAndSet(i, -4, 7));
135     assertEquals(7, aa.get(i));
136 dl 1.1 }
137     }
138    
139 dl 1.4 /**
140 dl 1.5 * compareAndSet in one thread enables another waiting for value
141     * to succeed
142     */
143 jsr166 1.14 public void testCompareAndSetInMultipleThreads() throws Exception {
144 dl 1.5 final AtomicIntegerArray a = new AtomicIntegerArray(1);
145     a.set(0, 1);
146 jsr166 1.15 Thread t = new Thread(new CheckedRunnable() {
147     public void realRun() {
148     while (!a.compareAndSet(0, 2, 3))
149     Thread.yield();
150     }});
151 jsr166 1.14
152     t.start();
153     assertTrue(a.compareAndSet(0, 1, 2));
154     t.join(LONG_DELAY_MS);
155     assertFalse(t.isAlive());
156 jsr166 1.25 assertEquals(3, a.get(0));
157 dl 1.5 }
158    
159     /**
160     * repeated weakCompareAndSet succeeds in changing value when equal
161 jsr166 1.11 * to expected
162 dl 1.4 */
163     public void testWeakCompareAndSet() {
164 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
165     for (int i = 0; i < SIZE; i++) {
166     aa.set(i, 1);
167 jsr166 1.30 do {} while (!aa.weakCompareAndSet(i, 1, 2));
168     do {} while (!aa.weakCompareAndSet(i, 2, -4));
169 jsr166 1.26 assertEquals(-4, aa.get(i));
170 jsr166 1.30 do {} while (!aa.weakCompareAndSet(i, -4, 7));
171 jsr166 1.26 assertEquals(7, aa.get(i));
172 dl 1.1 }
173     }
174    
175 dl 1.4 /**
176 jsr166 1.19 * getAndSet returns previous value and sets to given value at given index
177 dl 1.4 */
178     public void testGetAndSet() {
179 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
180     for (int i = 0; i < SIZE; i++) {
181     aa.set(i, 1);
182     assertEquals(1, aa.getAndSet(i, 0));
183     assertEquals(0, aa.getAndSet(i, -10));
184     assertEquals(-10, aa.getAndSet(i, 1));
185 dl 1.1 }
186     }
187    
188 dl 1.4 /**
189 jsr166 1.19 * getAndAdd returns previous value and adds given value
190 dl 1.4 */
191     public void testGetAndAdd() {
192 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
193     for (int i = 0; i < SIZE; i++) {
194     aa.set(i, 1);
195     assertEquals(1, aa.getAndAdd(i, 2));
196     assertEquals(3, aa.get(i));
197     assertEquals(3, aa.getAndAdd(i, -4));
198     assertEquals(-1, aa.get(i));
199 dl 1.1 }
200     }
201    
202 dl 1.4 /**
203 dl 1.5 * getAndDecrement returns previous value and decrements
204 dl 1.4 */
205     public void testGetAndDecrement() {
206 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
207     for (int i = 0; i < SIZE; i++) {
208     aa.set(i, 1);
209     assertEquals(1, aa.getAndDecrement(i));
210     assertEquals(0, aa.getAndDecrement(i));
211     assertEquals(-1, aa.getAndDecrement(i));
212 dl 1.1 }
213     }
214    
215 dl 1.4 /**
216 dl 1.5 * getAndIncrement returns previous value and increments
217 dl 1.4 */
218     public void testGetAndIncrement() {
219 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
220     for (int i = 0; i < SIZE; i++) {
221     aa.set(i, 1);
222     assertEquals(1, aa.getAndIncrement(i));
223     assertEquals(2, aa.get(i));
224     aa.set(i, -2);
225     assertEquals(-2, aa.getAndIncrement(i));
226     assertEquals(-1, aa.getAndIncrement(i));
227     assertEquals(0, aa.getAndIncrement(i));
228     assertEquals(1, aa.get(i));
229 dl 1.1 }
230     }
231    
232 dl 1.4 /**
233 jsr166 1.19 * addAndGet adds given value to current, and returns current value
234 dl 1.4 */
235 dl 1.1 public void testAddAndGet() {
236 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
237     for (int i = 0; i < SIZE; i++) {
238     aa.set(i, 1);
239     assertEquals(3, aa.addAndGet(i, 2));
240     assertEquals(3, aa.get(i));
241     assertEquals(-1, aa.addAndGet(i, -4));
242     assertEquals(-1, aa.get(i));
243 dl 1.1 }
244     }
245    
246 dl 1.4 /**
247 dl 1.5 * decrementAndGet decrements and returns current value
248 dl 1.4 */
249     public void testDecrementAndGet() {
250 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
251     for (int i = 0; i < SIZE; i++) {
252     aa.set(i, 1);
253     assertEquals(0, aa.decrementAndGet(i));
254     assertEquals(-1, aa.decrementAndGet(i));
255     assertEquals(-2, aa.decrementAndGet(i));
256     assertEquals(-2, aa.get(i));
257 dl 1.1 }
258     }
259    
260 dl 1.4 /**
261 jsr166 1.19 * incrementAndGet increments and returns current value
262 dl 1.4 */
263 dl 1.1 public void testIncrementAndGet() {
264 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
265     for (int i = 0; i < SIZE; i++) {
266     aa.set(i, 1);
267     assertEquals(2, aa.incrementAndGet(i));
268     assertEquals(2, aa.get(i));
269     aa.set(i, -2);
270     assertEquals(-1, aa.incrementAndGet(i));
271     assertEquals(0, aa.incrementAndGet(i));
272     assertEquals(1, aa.incrementAndGet(i));
273     assertEquals(1, aa.get(i));
274 dl 1.2 }
275     }
276    
277 jsr166 1.18 class Counter extends CheckedRunnable {
278 jsr166 1.26 final AtomicIntegerArray aa;
279 dl 1.3 volatile int counts;
280 jsr166 1.26 Counter(AtomicIntegerArray a) { aa = a; }
281 jsr166 1.18 public void realRun() {
282 dl 1.3 for (;;) {
283     boolean done = true;
284 jsr166 1.26 for (int i = 0; i < aa.length(); i++) {
285     int v = aa.get(i);
286 jsr166 1.18 assertTrue(v >= 0);
287 dl 1.3 if (v != 0) {
288     done = false;
289 jsr166 1.26 if (aa.compareAndSet(i, v, v-1))
290 dl 1.3 ++counts;
291     }
292     }
293     if (done)
294     break;
295     }
296     }
297     }
298    
299 dl 1.4 /**
300 dl 1.5 * Multiple threads using same array of counters successfully
301     * update a number of times equal to total count
302 dl 1.4 */
303 jsr166 1.14 public void testCountingInMultipleThreads() throws InterruptedException {
304 jsr166 1.26 final AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
305 jsr166 1.28 int countdown = 10000;
306 jsr166 1.26 for (int i = 0; i < SIZE; i++)
307 jsr166 1.28 aa.set(i, countdown);
308 jsr166 1.26 Counter c1 = new Counter(aa);
309     Counter c2 = new Counter(aa);
310 jsr166 1.14 Thread t1 = new Thread(c1);
311     Thread t2 = new Thread(c2);
312     t1.start();
313     t2.start();
314     t1.join();
315     t2.join();
316 jsr166 1.28 assertEquals(c1.counts+c2.counts, SIZE * countdown);
317 dl 1.3 }
318    
319 dl 1.4 /**
320 dl 1.5 * a deserialized serialized array holds same values
321 dl 1.4 */
322 jsr166 1.14 public void testSerialization() throws Exception {
323 jsr166 1.22 AtomicIntegerArray x = new AtomicIntegerArray(SIZE);
324     for (int i = 0; i < SIZE; i++)
325     x.set(i, -i);
326     AtomicIntegerArray y = serialClone(x);
327 jsr166 1.27 assertNotSame(x, y);
328 jsr166 1.22 assertEquals(x.length(), y.length());
329     for (int i = 0; i < SIZE; i++) {
330     assertEquals(x.get(i), y.get(i));
331 dl 1.1 }
332     }
333    
334 dl 1.9 /**
335     * toString returns current value.
336 jsr166 1.11 */
337 dl 1.9 public void testToString() {
338 jsr166 1.23 int[] a = { 17, 3, -42, 99, -7 };
339 jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(a);
340     assertEquals(Arrays.toString(a), aa.toString());
341 dl 1.9 }
342 dl 1.8
343 dl 1.1 }