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