ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicIntegerArrayTest.java
Revision: 1.17
Committed: Wed Aug 25 00:07:03 2010 UTC (13 years, 8 months ago) by jsr166
Branch: MAIN
Changes since 1.16: +2 -2 lines
Log Message:
whitespace

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 jsr166 1.17 public static void main(String[] args) {
17     junit.textui.TestRunner.run(suite());
18 dl 1.1 }
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 jsr166 1.16 assertEquals(-4,ai.get(i));
124 dl 1.1 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 jsr166 1.15 Thread t = new Thread(new CheckedRunnable() {
137     public void realRun() {
138     while (!a.compareAndSet(0, 2, 3))
139     Thread.yield();
140     }});
141 jsr166 1.14
142     t.start();
143     assertTrue(a.compareAndSet(0, 1, 2));
144     t.join(LONG_DELAY_MS);
145     assertFalse(t.isAlive());
146     assertEquals(a.get(0), 3);
147 dl 1.5 }
148    
149     /**
150     * repeated weakCompareAndSet succeeds in changing value when equal
151 jsr166 1.11 * to expected
152 dl 1.4 */
153     public void testWeakCompareAndSet() {
154 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
155 dl 1.3 for (int i = 0; i < SIZE; ++i) {
156 dl 1.1 ai.set(i, 1);
157 jsr166 1.12 while (!ai.weakCompareAndSet(i, 1,2));
158     while (!ai.weakCompareAndSet(i, 2,-4));
159 dl 1.1 assertEquals(-4,ai.get(i));
160 jsr166 1.12 while (!ai.weakCompareAndSet(i, -4,7));
161 dl 1.1 assertEquals(7,ai.get(i));
162     }
163     }
164    
165 dl 1.4 /**
166 dl 1.5 * getAndSet returns previous value and sets to given value at given index
167 dl 1.4 */
168     public void testGetAndSet() {
169 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
170 dl 1.3 for (int i = 0; i < SIZE; ++i) {
171 dl 1.1 ai.set(i, 1);
172     assertEquals(1,ai.getAndSet(i,0));
173     assertEquals(0,ai.getAndSet(i,-10));
174     assertEquals(-10,ai.getAndSet(i,1));
175     }
176     }
177    
178 dl 1.4 /**
179 dl 1.5 * getAndAdd returns previous value and adds given value
180 dl 1.4 */
181     public void testGetAndAdd() {
182 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
183 dl 1.3 for (int i = 0; i < SIZE; ++i) {
184 dl 1.1 ai.set(i, 1);
185     assertEquals(1,ai.getAndAdd(i,2));
186     assertEquals(3,ai.get(i));
187     assertEquals(3,ai.getAndAdd(i,-4));
188     assertEquals(-1,ai.get(i));
189     }
190     }
191    
192 dl 1.4 /**
193 dl 1.5 * getAndDecrement returns previous value and decrements
194 dl 1.4 */
195     public void testGetAndDecrement() {
196 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
197 dl 1.3 for (int i = 0; i < SIZE; ++i) {
198 dl 1.1 ai.set(i, 1);
199     assertEquals(1,ai.getAndDecrement(i));
200     assertEquals(0,ai.getAndDecrement(i));
201     assertEquals(-1,ai.getAndDecrement(i));
202     }
203     }
204    
205 dl 1.4 /**
206 dl 1.5 * getAndIncrement returns previous value and increments
207 dl 1.4 */
208     public void testGetAndIncrement() {
209 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
210 dl 1.3 for (int i = 0; i < SIZE; ++i) {
211 dl 1.1 ai.set(i, 1);
212     assertEquals(1,ai.getAndIncrement(i));
213     assertEquals(2,ai.get(i));
214     ai.set(i,-2);
215     assertEquals(-2,ai.getAndIncrement(i));
216     assertEquals(-1,ai.getAndIncrement(i));
217     assertEquals(0,ai.getAndIncrement(i));
218     assertEquals(1,ai.get(i));
219     }
220     }
221    
222 dl 1.4 /**
223 dl 1.5 * addAndGet adds given value to current, and returns current value
224 dl 1.4 */
225 dl 1.1 public void testAddAndGet() {
226 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
227 dl 1.3 for (int i = 0; i < SIZE; ++i) {
228 dl 1.1 ai.set(i, 1);
229     assertEquals(3,ai.addAndGet(i,2));
230     assertEquals(3,ai.get(i));
231     assertEquals(-1,ai.addAndGet(i,-4));
232     assertEquals(-1,ai.get(i));
233     }
234     }
235    
236 dl 1.4 /**
237 dl 1.5 * decrementAndGet decrements and returns current value
238 dl 1.4 */
239     public void testDecrementAndGet() {
240 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
241 dl 1.3 for (int i = 0; i < SIZE; ++i) {
242 dl 1.1 ai.set(i, 1);
243     assertEquals(0,ai.decrementAndGet(i));
244     assertEquals(-1,ai.decrementAndGet(i));
245     assertEquals(-2,ai.decrementAndGet(i));
246     assertEquals(-2,ai.get(i));
247     }
248     }
249    
250 dl 1.4 /**
251 dl 1.5 * incrementAndGet increments and returns current value
252 dl 1.4 */
253 dl 1.1 public void testIncrementAndGet() {
254 jsr166 1.11 AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
255 dl 1.3 for (int i = 0; i < SIZE; ++i) {
256 dl 1.1 ai.set(i, 1);
257     assertEquals(2,ai.incrementAndGet(i));
258     assertEquals(2,ai.get(i));
259     ai.set(i, -2);
260     assertEquals(-1,ai.incrementAndGet(i));
261     assertEquals(0,ai.incrementAndGet(i));
262     assertEquals(1,ai.incrementAndGet(i));
263     assertEquals(1,ai.get(i));
264 dl 1.2 }
265     }
266    
267 dl 1.3 static final int COUNTDOWN = 100000;
268 jsr166 1.11
269 dl 1.3 class Counter implements Runnable {
270     final AtomicIntegerArray ai;
271     volatile int counts;
272     Counter(AtomicIntegerArray a) { ai = a; }
273     public void run() {
274     for (;;) {
275     boolean done = true;
276     for (int i = 0; i < ai.length(); ++i) {
277     int v = ai.get(i);
278     threadAssertTrue(v >= 0);
279     if (v != 0) {
280     done = false;
281     if (ai.compareAndSet(i, v, v-1))
282     ++counts;
283     }
284     }
285     if (done)
286     break;
287     }
288     }
289     }
290    
291 dl 1.4 /**
292 dl 1.5 * Multiple threads using same array of counters successfully
293     * update a number of times equal to total count
294 dl 1.4 */
295 jsr166 1.14 public void testCountingInMultipleThreads() throws InterruptedException {
296     final AtomicIntegerArray ai = new AtomicIntegerArray(SIZE);
297     for (int i = 0; i < SIZE; ++i)
298     ai.set(i, COUNTDOWN);
299     Counter c1 = new Counter(ai);
300     Counter c2 = new Counter(ai);
301     Thread t1 = new Thread(c1);
302     Thread t2 = new Thread(c2);
303     t1.start();
304     t2.start();
305     t1.join();
306     t2.join();
307     assertEquals(c1.counts+c2.counts, SIZE * COUNTDOWN);
308 dl 1.3 }
309    
310    
311 dl 1.4 /**
312 dl 1.5 * a deserialized serialized array holds same values
313 dl 1.4 */
314 jsr166 1.14 public void testSerialization() throws Exception {
315 jsr166 1.11 AtomicIntegerArray l = new AtomicIntegerArray(SIZE);
316     for (int i = 0; i < SIZE; ++i)
317 dl 1.2 l.set(i, -i);
318    
319 jsr166 1.14 ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
320     ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
321     out.writeObject(l);
322     out.close();
323    
324     ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
325     ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
326     AtomicIntegerArray r = (AtomicIntegerArray) in.readObject();
327     for (int i = 0; i < SIZE; ++i) {
328     assertEquals(l.get(i), r.get(i));
329 dl 1.1 }
330     }
331    
332 dl 1.8
333 dl 1.9 /**
334     * toString returns current value.
335 jsr166 1.11 */
336 dl 1.9 public void testToString() {
337     int[] a = { 17, 3, -42, 99, -7};
338     AtomicIntegerArray ai = new AtomicIntegerArray(a);
339     assertEquals(Arrays.toString(a), ai.toString());
340     }
341 dl 1.8
342 dl 1.1 }