ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicLongArrayTest.java
Revision: 1.38
Committed: Tue Jan 26 13:33:05 2021 UTC (3 years, 3 months ago) by dl
Branch: MAIN
CVS Tags: HEAD
Changes since 1.37: +2 -0 lines
Log Message:
Replace Integer with Item class

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.19 * http://creativecommons.org/publicdomain/zero/1.0/
5 jsr166 1.10 * Other contributors include Andrew Wright, Jeffrey Hayes,
6     * Pat Fisher, Mike Judd.
7 dl 1.1 */
8    
9 jsr166 1.21 import java.util.Arrays;
10     import java.util.concurrent.atomic.AtomicLongArray;
11 dl 1.1
12 jsr166 1.28 import junit.framework.Test;
13     import junit.framework.TestSuite;
14    
15 dl 1.3 public class AtomicLongArrayTest extends JSR166TestCase {
16 jsr166 1.16 public static void main(String[] args) {
17 jsr166 1.31 main(suite(), args);
18 dl 1.1 }
19     public static Test suite() {
20     return new TestSuite(AtomicLongArrayTest.class);
21     }
22    
23 dl 1.4 /**
24 dl 1.5 * constructor creates array of given size with all elements zero
25 dl 1.4 */
26 jsr166 1.12 public void testConstructor() {
27 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
28     for (int i = 0; i < SIZE; i++)
29     assertEquals(0, aa.get(i));
30 dl 1.1 }
31    
32 dl 1.4 /**
33 dl 1.7 * constructor with null array throws NPE
34     */
35     public void testConstructor2NPE() {
36     try {
37     long[] a = null;
38 jsr166 1.30 new AtomicLongArray(a);
39 jsr166 1.13 shouldThrow();
40     } catch (NullPointerException success) {}
41 dl 1.7 }
42    
43     /**
44     * constructor with array is of same size and has all elements
45     */
46     public void testConstructor2() {
47 jsr166 1.22 long[] a = { 17L, 3L, -42L, 99L, -7L };
48 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(a);
49     assertEquals(a.length, aa.length());
50     for (int i = 0; i < a.length; i++)
51     assertEquals(a[i], aa.get(i));
52 dl 1.7 }
53    
54     /**
55 dl 1.5 * get and set for out of bound indices throw IndexOutOfBoundsException
56     */
57 dl 1.38 @SuppressWarnings("deprecation")
58 jsr166 1.12 public void testIndexing() {
59 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(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 jsr166 1.12 public void testGetSet() {
96 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(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.9 * get returns the last value lazySet at index by same thread
109     */
110 jsr166 1.12 public void testGetLazySet() {
111 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(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.9 }
120     }
121    
122     /**
123 dl 1.5 * compareAndSet succeeds in changing value if equal to expected else fails
124 dl 1.4 */
125 jsr166 1.12 public void testCompareAndSet() {
126 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(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.13 public void testCompareAndSetInMultipleThreads() throws InterruptedException {
144 dl 1.5 final AtomicLongArray a = new AtomicLongArray(1);
145     a.set(0, 1);
146 jsr166 1.14 Thread t = new Thread(new CheckedRunnable() {
147     public void realRun() {
148     while (!a.compareAndSet(0, 2, 3))
149     Thread.yield();
150     }});
151 jsr166 1.13
152     t.start();
153     assertTrue(a.compareAndSet(0, 1, 2));
154     t.join(LONG_DELAY_MS);
155     assertFalse(t.isAlive());
156 jsr166 1.24 assertEquals(3, a.get(0));
157 dl 1.5 }
158    
159     /**
160     * repeated weakCompareAndSet succeeds in changing value when equal
161 jsr166 1.10 * to expected
162 dl 1.4 */
163 dl 1.38 @SuppressWarnings("deprecation")
164 jsr166 1.12 public void testWeakCompareAndSet() {
165 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
166     for (int i = 0; i < SIZE; i++) {
167     aa.set(i, 1);
168 jsr166 1.29 do {} while (!aa.weakCompareAndSet(i, 1, 2));
169     do {} while (!aa.weakCompareAndSet(i, 2, -4));
170 jsr166 1.25 assertEquals(-4, aa.get(i));
171 jsr166 1.29 do {} while (!aa.weakCompareAndSet(i, -4, 7));
172 jsr166 1.25 assertEquals(7, aa.get(i));
173 dl 1.1 }
174     }
175    
176 dl 1.4 /**
177 jsr166 1.18 * getAndSet returns previous value and sets to given value at given index
178 dl 1.4 */
179 jsr166 1.12 public void testGetAndSet() {
180 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
181     for (int i = 0; i < SIZE; i++) {
182     aa.set(i, 1);
183     assertEquals(1, aa.getAndSet(i, 0));
184     assertEquals(0, aa.getAndSet(i, -10));
185     assertEquals(-10, aa.getAndSet(i, 1));
186 dl 1.1 }
187     }
188    
189 dl 1.4 /**
190 jsr166 1.18 * getAndAdd returns previous value and adds given value
191 dl 1.4 */
192 jsr166 1.12 public void testGetAndAdd() {
193 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
194     for (int i = 0; i < SIZE; i++) {
195     aa.set(i, 1);
196     assertEquals(1, aa.getAndAdd(i, 2));
197     assertEquals(3, aa.get(i));
198     assertEquals(3, aa.getAndAdd(i, -4));
199     assertEquals(-1, aa.get(i));
200 dl 1.1 }
201     }
202    
203 dl 1.4 /**
204 dl 1.5 * getAndDecrement returns previous value and decrements
205 dl 1.4 */
206 jsr166 1.12 public void testGetAndDecrement() {
207 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
208     for (int i = 0; i < SIZE; i++) {
209     aa.set(i, 1);
210     assertEquals(1, aa.getAndDecrement(i));
211     assertEquals(0, aa.getAndDecrement(i));
212     assertEquals(-1, aa.getAndDecrement(i));
213 dl 1.1 }
214     }
215    
216 dl 1.4 /**
217 dl 1.5 * getAndIncrement returns previous value and increments
218 dl 1.4 */
219 jsr166 1.12 public void testGetAndIncrement() {
220 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
221     for (int i = 0; i < SIZE; i++) {
222     aa.set(i, 1);
223     assertEquals(1, aa.getAndIncrement(i));
224     assertEquals(2, aa.get(i));
225     aa.set(i, -2);
226     assertEquals(-2, aa.getAndIncrement(i));
227     assertEquals(-1, aa.getAndIncrement(i));
228     assertEquals(0, aa.getAndIncrement(i));
229     assertEquals(1, aa.get(i));
230 dl 1.1 }
231     }
232    
233 dl 1.4 /**
234 jsr166 1.18 * addAndGet adds given value to current, and returns current value
235 dl 1.4 */
236 dl 1.1 public void testAddAndGet() {
237 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
238     for (int i = 0; i < SIZE; i++) {
239     aa.set(i, 1);
240     assertEquals(3, aa.addAndGet(i, 2));
241     assertEquals(3, aa.get(i));
242     assertEquals(-1, aa.addAndGet(i, -4));
243     assertEquals(-1, aa.get(i));
244 dl 1.1 }
245     }
246    
247 dl 1.4 /**
248 dl 1.5 * decrementAndGet decrements and returns current value
249 dl 1.4 */
250 jsr166 1.12 public void testDecrementAndGet() {
251 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
252     for (int i = 0; i < SIZE; i++) {
253     aa.set(i, 1);
254     assertEquals(0, aa.decrementAndGet(i));
255     assertEquals(-1, aa.decrementAndGet(i));
256     assertEquals(-2, aa.decrementAndGet(i));
257     assertEquals(-2, aa.get(i));
258 dl 1.1 }
259     }
260    
261 dl 1.4 /**
262 dl 1.5 * incrementAndGet increments and returns current value
263 dl 1.4 */
264 dl 1.1 public void testIncrementAndGet() {
265 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(SIZE);
266     for (int i = 0; i < SIZE; i++) {
267     aa.set(i, 1);
268     assertEquals(2, aa.incrementAndGet(i));
269     assertEquals(2, aa.get(i));
270     aa.set(i, -2);
271     assertEquals(-1, aa.incrementAndGet(i));
272     assertEquals(0, aa.incrementAndGet(i));
273     assertEquals(1, aa.incrementAndGet(i));
274     assertEquals(1, aa.get(i));
275 dl 1.1 }
276     }
277 dl 1.2
278 jsr166 1.17 class Counter extends CheckedRunnable {
279 jsr166 1.25 final AtomicLongArray aa;
280 jsr166 1.36 int decs;
281 jsr166 1.25 Counter(AtomicLongArray a) { aa = a; }
282 jsr166 1.17 public void realRun() {
283 dl 1.3 for (;;) {
284     boolean done = true;
285 jsr166 1.25 for (int i = 0; i < aa.length(); i++) {
286     long v = aa.get(i);
287 jsr166 1.17 assertTrue(v >= 0);
288 dl 1.3 if (v != 0) {
289     done = false;
290 jsr166 1.32 if (aa.compareAndSet(i, v, v - 1))
291 jsr166 1.36 decs++;
292 dl 1.3 }
293     }
294     if (done)
295     break;
296     }
297     }
298     }
299    
300 dl 1.4 /**
301 dl 1.5 * Multiple threads using same array of counters successfully
302     * update a number of times equal to total count
303 dl 1.4 */
304 jsr166 1.13 public void testCountingInMultipleThreads() throws InterruptedException {
305 jsr166 1.25 final AtomicLongArray aa = new AtomicLongArray(SIZE);
306 jsr166 1.27 long countdown = 10000;
307 jsr166 1.25 for (int i = 0; i < SIZE; i++)
308 jsr166 1.27 aa.set(i, countdown);
309 jsr166 1.25 Counter c1 = new Counter(aa);
310     Counter c2 = new Counter(aa);
311 jsr166 1.36 Thread t1 = newStartedThread(c1);
312     Thread t2 = newStartedThread(c2);
313 jsr166 1.13 t1.join();
314     t2.join();
315 jsr166 1.36 assertEquals(c1.decs + c2.decs, SIZE * countdown);
316 dl 1.3 }
317    
318 dl 1.4 /**
319 jsr166 1.37 * a deserialized/reserialized array holds same values in same order
320 dl 1.4 */
321 jsr166 1.13 public void testSerialization() throws Exception {
322 jsr166 1.21 AtomicLongArray x = new AtomicLongArray(SIZE);
323 jsr166 1.25 for (int i = 0; i < SIZE; i++)
324 jsr166 1.21 x.set(i, -i);
325     AtomicLongArray y = serialClone(x);
326 jsr166 1.26 assertNotSame(x, y);
327 jsr166 1.21 assertEquals(x.length(), y.length());
328 jsr166 1.25 for (int i = 0; i < SIZE; i++) {
329 jsr166 1.21 assertEquals(x.get(i), y.get(i));
330 dl 1.2 }
331 dl 1.8 }
332    
333     /**
334     * toString returns current value.
335 jsr166 1.10 */
336 dl 1.8 public void testToString() {
337 jsr166 1.22 long[] a = { 17, 3, -42, 99, -7 };
338 jsr166 1.25 AtomicLongArray aa = new AtomicLongArray(a);
339     assertEquals(Arrays.toString(a), aa.toString());
340 dl 1.2 }
341    
342 dl 1.1 }