ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicIntegerArrayTest.java
Revision: 1.26
Committed: Wed Aug 10 07:14:48 2011 UTC (12 years, 9 months ago) by jsr166
Branch: MAIN
Changes since 1.25: +137 -127 lines
Log Message:
minor improvements

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