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

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8