[cvs] / jsr166 / src / test / tck / AtomicIntegerArrayTest.java Repository:
ViewVC logotype

Annotation of /jsr166/src/test/tck/AtomicIntegerArrayTest.java

Parent Directory Parent Directory | Revision Log Revision Log


Revision 1.31 - (view) (download)

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 :     junit.textui.TestRunner.run(suite());
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 : jsr166 1.13 public void testIndexing() {
59 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(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 :     public void testGetSet() {
96 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(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.10 * get returns the last value lazySet at index by same thread
109 :     */
110 :     public void testGetLazySet() {
111 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(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.10 }
120 :     }
121 :    
122 :     /**
123 : dl 1.5 * compareAndSet succeeds in changing value if equal to expected else fails
124 : dl 1.4 */
125 :     public void testCompareAndSet() {
126 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(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.14 public void testCompareAndSetInMultipleThreads() throws Exception {
144 : dl 1.5 final AtomicIntegerArray a = new AtomicIntegerArray(1);
145 :     a.set(0, 1);
146 : jsr166 1.15 Thread t = new Thread(new CheckedRunnable() {
147 :     public void realRun() {
148 :     while (!a.compareAndSet(0, 2, 3))
149 :     Thread.yield();
150 :     }});
151 : jsr166 1.14
152 :     t.start();
153 :     assertTrue(a.compareAndSet(0, 1, 2));
154 :     t.join(LONG_DELAY_MS);
155 :     assertFalse(t.isAlive());
156 : jsr166 1.25 assertEquals(3, a.get(0));
157 : dl 1.5 }
158 :    
159 :     /**
160 :     * repeated weakCompareAndSet succeeds in changing value when equal
161 : jsr166 1.11 * to expected
162 : dl 1.4 */
163 :     public void testWeakCompareAndSet() {
164 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
165 :     for (int i = 0; i < SIZE; i++) {
166 :     aa.set(i, 1);
167 : jsr166 1.30 do {} while (!aa.weakCompareAndSet(i, 1, 2));
168 :     do {} while (!aa.weakCompareAndSet(i, 2, -4));
169 : jsr166 1.26 assertEquals(-4, aa.get(i));
170 : jsr166 1.30 do {} while (!aa.weakCompareAndSet(i, -4, 7));
171 : jsr166 1.26 assertEquals(7, aa.get(i));
172 : dl 1.1 }
173 :     }
174 :    
175 : dl 1.4 /**
176 : jsr166 1.19 * getAndSet returns previous value and sets to given value at given index
177 : dl 1.4 */
178 :     public void testGetAndSet() {
179 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
180 :     for (int i = 0; i < SIZE; i++) {
181 :     aa.set(i, 1);
182 :     assertEquals(1, aa.getAndSet(i, 0));
183 :     assertEquals(0, aa.getAndSet(i, -10));
184 :     assertEquals(-10, aa.getAndSet(i, 1));
185 : dl 1.1 }
186 :     }
187 :    
188 : dl 1.4 /**
189 : jsr166 1.19 * getAndAdd returns previous value and adds given value
190 : dl 1.4 */
191 :     public void testGetAndAdd() {
192 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
193 :     for (int i = 0; i < SIZE; i++) {
194 :     aa.set(i, 1);
195 :     assertEquals(1, aa.getAndAdd(i, 2));
196 :     assertEquals(3, aa.get(i));
197 :     assertEquals(3, aa.getAndAdd(i, -4));
198 :     assertEquals(-1, aa.get(i));
199 : dl 1.1 }
200 :     }
201 :    
202 : dl 1.4 /**
203 : dl 1.5 * getAndDecrement returns previous value and decrements
204 : dl 1.4 */
205 :     public void testGetAndDecrement() {
206 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
207 :     for (int i = 0; i < SIZE; i++) {
208 :     aa.set(i, 1);
209 :     assertEquals(1, aa.getAndDecrement(i));
210 :     assertEquals(0, aa.getAndDecrement(i));
211 :     assertEquals(-1, aa.getAndDecrement(i));
212 : dl 1.1 }
213 :     }
214 :    
215 : dl 1.4 /**
216 : dl 1.5 * getAndIncrement returns previous value and increments
217 : dl 1.4 */
218 :     public void testGetAndIncrement() {
219 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
220 :     for (int i = 0; i < SIZE; i++) {
221 :     aa.set(i, 1);
222 :     assertEquals(1, aa.getAndIncrement(i));
223 :     assertEquals(2, aa.get(i));
224 :     aa.set(i, -2);
225 :     assertEquals(-2, aa.getAndIncrement(i));
226 :     assertEquals(-1, aa.getAndIncrement(i));
227 :     assertEquals(0, aa.getAndIncrement(i));
228 :     assertEquals(1, aa.get(i));
229 : dl 1.1 }
230 :     }
231 :    
232 : dl 1.4 /**
233 : jsr166 1.19 * addAndGet adds given value to current, and returns current value
234 : dl 1.4 */
235 : dl 1.1 public void testAddAndGet() {
236 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
237 :     for (int i = 0; i < SIZE; i++) {
238 :     aa.set(i, 1);
239 :     assertEquals(3, aa.addAndGet(i, 2));
240 :     assertEquals(3, aa.get(i));
241 :     assertEquals(-1, aa.addAndGet(i, -4));
242 :     assertEquals(-1, aa.get(i));
243 : dl 1.1 }
244 :     }
245 :    
246 : dl 1.4 /**
247 : dl 1.5 * decrementAndGet decrements and returns current value
248 : dl 1.4 */
249 :     public void testDecrementAndGet() {
250 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
251 :     for (int i = 0; i < SIZE; i++) {
252 :     aa.set(i, 1);
253 :     assertEquals(0, aa.decrementAndGet(i));
254 :     assertEquals(-1, aa.decrementAndGet(i));
255 :     assertEquals(-2, aa.decrementAndGet(i));
256 :     assertEquals(-2, aa.get(i));
257 : dl 1.1 }
258 :     }
259 :    
260 : dl 1.4 /**
261 : jsr166 1.19 * incrementAndGet increments and returns current value
262 : dl 1.4 */
263 : dl 1.1 public void testIncrementAndGet() {
264 : jsr166 1.26 AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
265 :     for (int i = 0; i < SIZE; i++) {
266 :     aa.set(i, 1);
267 :     assertEquals(2, aa.incrementAndGet(i));
268 :     assertEquals(2, aa.get(i));
269 :     aa.set(i, -2);
270 :     assertEquals(-1, aa.incrementAndGet(i));
271 :     assertEquals(0, aa.incrementAndGet(i));
272 :     assertEquals(1, aa.incrementAndGet(i));
273 :     assertEquals(1, aa.get(i));
274 : dl 1.2 }
275 :     }
276 :    
277 : jsr166 1.18 class Counter extends CheckedRunnable {
278 : jsr166 1.26 final AtomicIntegerArray aa;
279 : dl 1.3 volatile int counts;
280 : jsr166 1.26 Counter(AtomicIntegerArray a) { aa = a; }
281 : jsr166 1.18 public void realRun() {
282 : dl 1.3 for (;;) {
283 :     boolean done = true;
284 : jsr166 1.26 for (int i = 0; i < aa.length(); i++) {
285 :     int v = aa.get(i);
286 : jsr166 1.18 assertTrue(v >= 0);
287 : dl 1.3 if (v != 0) {
288 :     done = false;
289 : jsr166 1.26 if (aa.compareAndSet(i, v, v-1))
290 : dl 1.3 ++counts;
291 :     }
292 :     }
293 :     if (done)
294 :     break;
295 :     }
296 :     }
297 :     }
298 :    
299 : dl 1.4 /**
300 : dl 1.5 * Multiple threads using same array of counters successfully
301 :     * update a number of times equal to total count
302 : dl 1.4 */
303 : jsr166 1.14 public void testCountingInMultipleThreads() throws InterruptedException {
304 : jsr166 1.26 final AtomicIntegerArray aa = new AtomicIntegerArray(SIZE);
305 : jsr166 1.28 int countdown = 10000;
306 : jsr166 1.26 for (int i = 0; i < SIZE; i++)
307 : jsr166 1.28 aa.set(i, countdown);
308 : jsr166 1.26 Counter c1 = new Counter(aa);
309 :     Counter c2 = new Counter(aa);
310 : jsr166 1.14 Thread t1 = new Thread(c1);
311 :     Thread t2 = new Thread(c2);
312 :     t1.start();
313 :     t2.start();
314 :     t1.join();
315 :     t2.join();
316 : jsr166 1.28 assertEquals(c1.counts+c2.counts, SIZE * countdown);
317 : dl 1.3 }
318 :    
319 : dl 1.4 /**
320 : dl 1.5 * a deserialized serialized array holds same values
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 }

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8