ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicIntegerArrayTest.java
Revision: 1.14
Committed: Tue Nov 17 02:37:16 2009 UTC (14 years, 5 months ago) by jsr166
Branch: MAIN
Changes since 1.13: +37 -49 lines
Log Message:
clean up exception handling; add missing shouldThrows

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     * http://creativecommons.org/licenses/publicdomain
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     import java.util.concurrent.atomic.*;
11 dl 1.2 import java.io.*;
12 dl 1.9 import java.util.*;
13 dl 1.1
14 dl 1.3 public class AtomicIntegerArrayTest extends JSR166TestCase {
15 dl 1.1
16     public static void main (String[] args) {
17     junit.textui.TestRunner.run (suite());
18     }
19     public static Test suite() {
20     return new TestSuite(AtomicIntegerArrayTest.class);
21     }
22    
23 dl 1.3
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 dl 1.3 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
29 jsr166 1.11 for (int i = 0; i < SIZE; ++i)
30 dl 1.1 assertEquals(0,ai.get(i));
31     }
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     AtomicIntegerArray ai = 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     int[] a = { 17, 3, -42, 99, -7};
49     AtomicIntegerArray ai = new AtomicIntegerArray(a);
50     assertEquals(a.length, ai.length());
51 jsr166 1.11 for (int i = 0; i < a.length; ++i)
52 dl 1.7 assertEquals(a[i], ai.get(i));
53     }
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 dl 1.5 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
60     try {
61     ai.get(SIZE);
62 jsr166 1.14 shouldThrow();
63 jsr166 1.13 } catch (IndexOutOfBoundsException success) {
64 dl 1.5 }
65     try {
66     ai.get(-1);
67 jsr166 1.14 shouldThrow();
68 jsr166 1.13 } catch (IndexOutOfBoundsException success) {
69 dl 1.5 }
70     try {
71     ai.set(SIZE, 0);
72 jsr166 1.14 shouldThrow();
73 jsr166 1.13 } catch (IndexOutOfBoundsException success) {
74 dl 1.5 }
75     try {
76     ai.set(-1, 0);
77 jsr166 1.14 shouldThrow();
78 jsr166 1.13 } catch (IndexOutOfBoundsException success) {
79 dl 1.5 }
80     }
81    
82     /**
83     * get returns the last value set at index
84 dl 1.4 */
85     public void testGetSet() {
86 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
87 dl 1.3 for (int i = 0; i < SIZE; ++i) {
88 dl 1.1 ai.set(i, 1);
89     assertEquals(1,ai.get(i));
90     ai.set(i, 2);
91     assertEquals(2,ai.get(i));
92     ai.set(i, -3);
93     assertEquals(-3,ai.get(i));
94     }
95     }
96    
97 dl 1.4 /**
98 dl 1.10 * get returns the last value lazySet at index by same thread
99     */
100     public void testGetLazySet() {
101 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
102 dl 1.10 for (int i = 0; i < SIZE; ++i) {
103     ai.lazySet(i, 1);
104     assertEquals(1,ai.get(i));
105     ai.lazySet(i, 2);
106     assertEquals(2,ai.get(i));
107     ai.lazySet(i, -3);
108     assertEquals(-3,ai.get(i));
109     }
110     }
111    
112     /**
113 dl 1.5 * compareAndSet succeeds in changing value if equal to expected else fails
114 dl 1.4 */
115     public void testCompareAndSet() {
116 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
117 dl 1.3 for (int i = 0; i < SIZE; ++i) {
118 dl 1.1 ai.set(i, 1);
119     assertTrue(ai.compareAndSet(i, 1,2));
120     assertTrue(ai.compareAndSet(i, 2,-4));
121     assertEquals(-4,ai.get(i));
122     assertFalse(ai.compareAndSet(i, -5,7));
123     assertFalse((7 == ai.get(i)));
124     assertTrue(ai.compareAndSet(i, -4,7));
125     assertEquals(7,ai.get(i));
126     }
127     }
128    
129 dl 1.4 /**
130 dl 1.5 * compareAndSet in one thread enables another waiting for value
131     * to succeed
132     */
133 jsr166 1.14 public void testCompareAndSetInMultipleThreads() throws Exception {
134 dl 1.5 final AtomicIntegerArray a = new AtomicIntegerArray(1);
135     a.set(0, 1);
136     Thread t = new Thread(new Runnable() {
137     public void run() {
138 jsr166 1.12 while (!a.compareAndSet(0, 2, 3)) Thread.yield();
139 dl 1.5 }});
140 jsr166 1.14
141     t.start();
142     assertTrue(a.compareAndSet(0, 1, 2));
143     t.join(LONG_DELAY_MS);
144     assertFalse(t.isAlive());
145     assertEquals(a.get(0), 3);
146 dl 1.5 }
147    
148     /**
149     * repeated weakCompareAndSet succeeds in changing value when equal
150 jsr166 1.11 * to expected
151 dl 1.4 */
152     public void testWeakCompareAndSet() {
153 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
154 dl 1.3 for (int i = 0; i < SIZE; ++i) {
155 dl 1.1 ai.set(i, 1);
156 jsr166 1.12 while (!ai.weakCompareAndSet(i, 1,2));
157     while (!ai.weakCompareAndSet(i, 2,-4));
158 dl 1.1 assertEquals(-4,ai.get(i));
159 jsr166 1.12 while (!ai.weakCompareAndSet(i, -4,7));
160 dl 1.1 assertEquals(7,ai.get(i));
161     }
162     }
163    
164 dl 1.4 /**
165 dl 1.5 * getAndSet returns previous value and sets to given value at given index
166 dl 1.4 */
167     public void testGetAndSet() {
168 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
169 dl 1.3 for (int i = 0; i < SIZE; ++i) {
170 dl 1.1 ai.set(i, 1);
171     assertEquals(1,ai.getAndSet(i,0));
172     assertEquals(0,ai.getAndSet(i,-10));
173     assertEquals(-10,ai.getAndSet(i,1));
174     }
175     }
176    
177 dl 1.4 /**
178 dl 1.5 * getAndAdd returns previous value and adds given value
179 dl 1.4 */
180     public void testGetAndAdd() {
181 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
182 dl 1.3 for (int i = 0; i < SIZE; ++i) {
183 dl 1.1 ai.set(i, 1);
184     assertEquals(1,ai.getAndAdd(i,2));
185     assertEquals(3,ai.get(i));
186     assertEquals(3,ai.getAndAdd(i,-4));
187     assertEquals(-1,ai.get(i));
188     }
189     }
190    
191 dl 1.4 /**
192 dl 1.5 * getAndDecrement returns previous value and decrements
193 dl 1.4 */
194     public void testGetAndDecrement() {
195 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
196 dl 1.3 for (int i = 0; i < SIZE; ++i) {
197 dl 1.1 ai.set(i, 1);
198     assertEquals(1,ai.getAndDecrement(i));
199     assertEquals(0,ai.getAndDecrement(i));
200     assertEquals(-1,ai.getAndDecrement(i));
201     }
202     }
203    
204 dl 1.4 /**
205 dl 1.5 * getAndIncrement returns previous value and increments
206 dl 1.4 */
207     public void testGetAndIncrement() {
208 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
209 dl 1.3 for (int i = 0; i < SIZE; ++i) {
210 dl 1.1 ai.set(i, 1);
211     assertEquals(1,ai.getAndIncrement(i));
212     assertEquals(2,ai.get(i));
213     ai.set(i,-2);
214     assertEquals(-2,ai.getAndIncrement(i));
215     assertEquals(-1,ai.getAndIncrement(i));
216     assertEquals(0,ai.getAndIncrement(i));
217     assertEquals(1,ai.get(i));
218     }
219     }
220    
221 dl 1.4 /**
222 dl 1.5 * addAndGet adds given value to current, and returns current value
223 dl 1.4 */
224 dl 1.1 public void testAddAndGet() {
225 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
226 dl 1.3 for (int i = 0; i < SIZE; ++i) {
227 dl 1.1 ai.set(i, 1);
228     assertEquals(3,ai.addAndGet(i,2));
229     assertEquals(3,ai.get(i));
230     assertEquals(-1,ai.addAndGet(i,-4));
231     assertEquals(-1,ai.get(i));
232     }
233     }
234    
235 dl 1.4 /**
236 dl 1.5 * decrementAndGet decrements and returns current value
237 dl 1.4 */
238     public void testDecrementAndGet() {
239 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
240 dl 1.3 for (int i = 0; i < SIZE; ++i) {
241 dl 1.1 ai.set(i, 1);
242     assertEquals(0,ai.decrementAndGet(i));
243     assertEquals(-1,ai.decrementAndGet(i));
244     assertEquals(-2,ai.decrementAndGet(i));
245     assertEquals(-2,ai.get(i));
246     }
247     }
248    
249 dl 1.4 /**
250 dl 1.5 * incrementAndGet increments and returns current value
251 dl 1.4 */
252 dl 1.1 public void testIncrementAndGet() {
253 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
254 dl 1.3 for (int i = 0; i < SIZE; ++i) {
255 dl 1.1 ai.set(i, 1);
256     assertEquals(2,ai.incrementAndGet(i));
257     assertEquals(2,ai.get(i));
258     ai.set(i, -2);
259     assertEquals(-1,ai.incrementAndGet(i));
260     assertEquals(0,ai.incrementAndGet(i));
261     assertEquals(1,ai.incrementAndGet(i));
262     assertEquals(1,ai.get(i));
263 dl 1.2 }
264     }
265    
266 dl 1.3 static final int COUNTDOWN = 100000;
267 jsr166 1.11
268 dl 1.3 class Counter implements Runnable {
269     final AtomicIntegerArray ai;
270     volatile int counts;
271     Counter(AtomicIntegerArray a) { ai = a; }
272     public void run() {
273     for (;;) {
274     boolean done = true;
275     for (int i = 0; i < ai.length(); ++i) {
276     int v = ai.get(i);
277     threadAssertTrue(v >= 0);
278     if (v != 0) {
279     done = false;
280     if (ai.compareAndSet(i, v, v-1))
281     ++counts;
282     }
283     }
284     if (done)
285     break;
286     }
287     }
288     }
289    
290 dl 1.4 /**
291 dl 1.5 * Multiple threads using same array of counters successfully
292     * update a number of times equal to total count
293 dl 1.4 */
294 jsr166 1.14 public void testCountingInMultipleThreads() throws InterruptedException {
295     final AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
296     for (int i = 0; i < SIZE; ++i)
297     ai.set(i, COUNTDOWN);
298     Counter c1 = new Counter(ai);
299     Counter c2 = new Counter(ai);
300     Thread t1 = new Thread(c1);
301     Thread t2 = new Thread(c2);
302     t1.start();
303     t2.start();
304     t1.join();
305     t2.join();
306     assertEquals(c1.counts+c2.counts, SIZE * COUNTDOWN);
307 dl 1.3 }
308    
309    
310 dl 1.4 /**
311 dl 1.5 * a deserialized serialized array holds same values
312 dl 1.4 */
313 jsr166 1.14 public void testSerialization() throws Exception {
314 jsr166 1.11 AtomicIntegerArray l = new AtomicIntegerArray(SIZE);
315     for (int i = 0; i < SIZE; ++i)
316 dl 1.2 l.set(i, -i);
317    
318 jsr166 1.14 ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
319     ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
320     out.writeObject(l);
321     out.close();
322    
323     ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
324     ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
325     AtomicIntegerArray r = (AtomicIntegerArray) in.readObject();
326     for (int i = 0; i < SIZE; ++i) {
327     assertEquals(l.get(i), r.get(i));
328 dl 1.1 }
329     }
330    
331 dl 1.8
332 dl 1.9 /**
333     * toString returns current value.
334 jsr166 1.11 */
335 dl 1.9 public void testToString() {
336     int[] a = { 17, 3, -42, 99, -7};
337     AtomicIntegerArray ai = new AtomicIntegerArray(a);
338     assertEquals(Arrays.toString(a), ai.toString());
339     }
340 dl 1.8
341 dl 1.1 }