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

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8