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