ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicReferenceArrayTest.java
(Generate patch)

Comparing jsr166/src/test/tck/AtomicReferenceArrayTest.java (file contents):
Revision 1.3 by dl, Sun Sep 14 20:42:40 2003 UTC vs.
Revision 1.32 by jsr166, Sat Apr 25 04:55:30 2015 UTC

# Line 1 | Line 1
1   /*
2 < * Written by members of JCP JSR-166 Expert Group and released to the
3 < * public domain. Use, modify, and redistribute this code in any way
4 < * without acknowledgement. Other contributors include Andrew Wright,
5 < * Jeffrey Hayes, Pat Fischer, Mike Judd.
2 > * 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/publicdomain/zero/1.0/
5 > * Other contributors include Andrew Wright, Jeffrey Hayes,
6 > * Pat Fisher, Mike Judd.
7   */
8  
9 < import junit.framework.*;
10 < import java.util.concurrent.atomic.*;
10 < import java.io.*;
11 <
12 < public class AtomicReferenceArrayTest extends JSR166TestCase
13 < {
14 <    public static void main (String[] args) {
15 <        junit.textui.TestRunner.run (suite());
16 <    }
17 <    public static Test suite() {
18 <        return new TestSuite(AtomicReferenceArrayTest.class);
19 <    }
9 > import java.util.Arrays;
10 > import java.util.concurrent.atomic.AtomicReferenceArray;
11  
12 <    public void testConstructor(){
13 <        AtomicReferenceArray<Integer> ai = new AtomicReferenceArray<Integer>(SIZE);
23 <        for (int i = 0; i < SIZE; ++i) {
24 <            assertNull(ai.get(i));
25 <        }
26 <    }
27 <
28 <    public void testGetSet(){
29 <        AtomicReferenceArray ai = new AtomicReferenceArray(SIZE);
30 <        for (int i = 0; i < SIZE; ++i) {
31 <            ai.set(i, one);
32 <            assertEquals(one,ai.get(i));
33 <            ai.set(i, two);
34 <            assertEquals(two,ai.get(i));
35 <            ai.set(i, m3);
36 <            assertEquals(m3,ai.get(i));
37 <        }
38 <    }
12 > import junit.framework.Test;
13 > import junit.framework.TestSuite;
14  
15 <    public void testCompareAndSet(){
16 <        AtomicReferenceArray ai = new AtomicReferenceArray(SIZE);
17 <        for (int i = 0; i < SIZE; ++i) {
43 <            ai.set(i, one);
44 <            assertTrue(ai.compareAndSet(i, one,two));
45 <            assertTrue(ai.compareAndSet(i, two,m4));
46 <            assertEquals(m4,ai.get(i));
47 <            assertFalse(ai.compareAndSet(i, m5,seven));
48 <            assertFalse((seven.equals(ai.get(i))));
49 <            assertTrue(ai.compareAndSet(i, m4,seven));
50 <            assertEquals(seven,ai.get(i));
51 <        }
15 > public class AtomicReferenceArrayTest extends JSR166TestCase {
16 >    public static void main(String[] args) {
17 >        main(suite(), args);
18      }
19 <
20 <    public void testWeakCompareAndSet(){
55 <        AtomicReferenceArray ai = new AtomicReferenceArray(SIZE);
56 <        for (int i = 0; i < SIZE; ++i) {
57 <            ai.set(i, one);
58 <            while(!ai.weakCompareAndSet(i, one,two));
59 <            while(!ai.weakCompareAndSet(i, two,m4));
60 <            assertEquals(m4,ai.get(i));
61 <            while(!ai.weakCompareAndSet(i, m4,seven));
62 <            assertEquals(seven,ai.get(i));
63 <        }
19 >    public static Test suite() {
20 >        return new TestSuite(AtomicReferenceArrayTest.class);
21      }
22  
23 <    public void testGetAndSet(){
24 <        AtomicReferenceArray ai = new AtomicReferenceArray(SIZE);
25 <        for (int i = 0; i < SIZE; ++i) {
26 <            ai.set(i, one);
27 <            assertEquals(one,ai.getAndSet(i,zero));
28 <            assertEquals(0,ai.getAndSet(i,m10));
29 <            assertEquals(m10,ai.getAndSet(i,one));
23 >    /**
24 >     * constructor creates array of given size with all elements null
25 >     */
26 >    public void testConstructor() {
27 >        AtomicReferenceArray<Integer> aa = new AtomicReferenceArray<Integer>(SIZE);
28 >        for (int i = 0; i < SIZE; i++) {
29 >            assertNull(aa.get(i));
30          }
31      }
32  
33 <    public void testSerialization() {
34 <        AtomicReferenceArray l = new AtomicReferenceArray(SIZE);
35 <        for (int i = 0; i < SIZE; ++i) {
36 <            l.set(i, new Integer(-i));
80 <        }
81 <
33 >    /**
34 >     * constructor with null array throws NPE
35 >     */
36 >    public void testConstructor2NPE() {
37          try {
38 <            ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
39 <            ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
40 <            out.writeObject(l);
41 <            out.close();
42 <
43 <            ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
44 <            ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
45 <            AtomicReferenceArray r = (AtomicReferenceArray) in.readObject();
46 <            assertEquals(l.length(), r.length());
47 <            for (int i = 0; i < SIZE; ++i) {
48 <                assertEquals(r.get(i), l.get(i));
49 <            }
50 <        } catch(Exception e){
51 <            e.printStackTrace();
52 <            fail("unexpected exception");
53 <        }
38 >            Integer[] a = null;
39 >            new AtomicReferenceArray<Integer>(a);
40 >            shouldThrow();
41 >        } catch (NullPointerException success) {}
42 >    }
43 >
44 >    /**
45 >     * constructor with array is of same size and has all elements
46 >     */
47 >    public void testConstructor2() {
48 >        Integer[] a = { two, one, three, four, seven };
49 >        AtomicReferenceArray<Integer> aa = new AtomicReferenceArray<Integer>(a);
50 >        assertEquals(a.length, aa.length());
51 >        for (int i = 0; i < a.length; i++)
52 >            assertEquals(a[i], aa.get(i));
53 >    }
54 >
55 >    /**
56 >     * Initialize AtomicReferenceArray<Class> with SubClass[]
57 >     */
58 >    public void testConstructorSubClassArray() {
59 >        Integer[] a = { two, one, three, four, seven };
60 >        AtomicReferenceArray<Number> aa = new AtomicReferenceArray<Number>(a);
61 >        assertEquals(a.length, aa.length());
62 >        for (int i = 0; i < a.length; i++) {
63 >            assertSame(a[i], aa.get(i));
64 >            Long x = Long.valueOf(i);
65 >            aa.set(i, x);
66 >            assertSame(x, aa.get(i));
67 >        }
68 >    }
69 >
70 >    /**
71 >     * get and set for out of bound indices throw IndexOutOfBoundsException
72 >     */
73 >    public void testIndexing() {
74 >        AtomicReferenceArray<Integer> aa = new AtomicReferenceArray<Integer>(SIZE);
75 >        for (int index : new int[] { -1, SIZE }) {
76 >            try {
77 >                aa.get(index);
78 >                shouldThrow();
79 >            } catch (IndexOutOfBoundsException success) {}
80 >            try {
81 >                aa.set(index, null);
82 >                shouldThrow();
83 >            } catch (IndexOutOfBoundsException success) {}
84 >            try {
85 >                aa.lazySet(index, null);
86 >                shouldThrow();
87 >            } catch (IndexOutOfBoundsException success) {}
88 >            try {
89 >                aa.compareAndSet(index, null, null);
90 >                shouldThrow();
91 >            } catch (IndexOutOfBoundsException success) {}
92 >            try {
93 >                aa.weakCompareAndSet(index, null, null);
94 >                shouldThrow();
95 >            } catch (IndexOutOfBoundsException success) {}
96 >        }
97 >    }
98 >
99 >    /**
100 >     * get returns the last value set at index
101 >     */
102 >    public void testGetSet() {
103 >        AtomicReferenceArray aa = new AtomicReferenceArray(SIZE);
104 >        for (int i = 0; i < SIZE; i++) {
105 >            aa.set(i, one);
106 >            assertSame(one, aa.get(i));
107 >            aa.set(i, two);
108 >            assertSame(two, aa.get(i));
109 >            aa.set(i, m3);
110 >            assertSame(m3, aa.get(i));
111 >        }
112 >    }
113 >
114 >    /**
115 >     * get returns the last value lazySet at index by same thread
116 >     */
117 >    public void testGetLazySet() {
118 >        AtomicReferenceArray aa = new AtomicReferenceArray(SIZE);
119 >        for (int i = 0; i < SIZE; i++) {
120 >            aa.lazySet(i, one);
121 >            assertSame(one, aa.get(i));
122 >            aa.lazySet(i, two);
123 >            assertSame(two, aa.get(i));
124 >            aa.lazySet(i, m3);
125 >            assertSame(m3, aa.get(i));
126 >        }
127 >    }
128 >
129 >    /**
130 >     * compareAndSet succeeds in changing value if equal to expected else fails
131 >     */
132 >    public void testCompareAndSet() {
133 >        AtomicReferenceArray aa = new AtomicReferenceArray(SIZE);
134 >        for (int i = 0; i < SIZE; i++) {
135 >            aa.set(i, one);
136 >            assertTrue(aa.compareAndSet(i, one, two));
137 >            assertTrue(aa.compareAndSet(i, two, m4));
138 >            assertSame(m4, aa.get(i));
139 >            assertFalse(aa.compareAndSet(i, m5, seven));
140 >            assertSame(m4, aa.get(i));
141 >            assertTrue(aa.compareAndSet(i, m4, seven));
142 >            assertSame(seven, aa.get(i));
143 >        }
144 >    }
145 >
146 >    /**
147 >     * compareAndSet in one thread enables another waiting for value
148 >     * to succeed
149 >     */
150 >    public void testCompareAndSetInMultipleThreads() throws InterruptedException {
151 >        final AtomicReferenceArray a = new AtomicReferenceArray(1);
152 >        a.set(0, one);
153 >        Thread t = new Thread(new CheckedRunnable() {
154 >            public void realRun() {
155 >                while (!a.compareAndSet(0, two, three))
156 >                    Thread.yield();
157 >            }});
158 >
159 >        t.start();
160 >        assertTrue(a.compareAndSet(0, one, two));
161 >        t.join(LONG_DELAY_MS);
162 >        assertFalse(t.isAlive());
163 >        assertSame(three, a.get(0));
164 >    }
165 >
166 >    /**
167 >     * repeated weakCompareAndSet succeeds in changing value when equal
168 >     * to expected
169 >     */
170 >    public void testWeakCompareAndSet() {
171 >        AtomicReferenceArray aa = new AtomicReferenceArray(SIZE);
172 >        for (int i = 0; i < SIZE; i++) {
173 >            aa.set(i, one);
174 >            do {} while (!aa.weakCompareAndSet(i, one, two));
175 >            do {} while (!aa.weakCompareAndSet(i, two, m4));
176 >            assertSame(m4, aa.get(i));
177 >            do {} while (!aa.weakCompareAndSet(i, m4, seven));
178 >            assertSame(seven, aa.get(i));
179 >        }
180 >    }
181 >
182 >    /**
183 >     * getAndSet returns previous value and sets to given value at given index
184 >     */
185 >    public void testGetAndSet() {
186 >        AtomicReferenceArray aa = new AtomicReferenceArray(SIZE);
187 >        for (int i = 0; i < SIZE; i++) {
188 >            aa.set(i, one);
189 >            assertSame(one, aa.getAndSet(i, zero));
190 >            assertSame(zero, aa.getAndSet(i, m10));
191 >            assertSame(m10, aa.getAndSet(i, one));
192 >        }
193 >    }
194 >
195 >    /**
196 >     * a deserialized serialized array holds same values
197 >     */
198 >    public void testSerialization() throws Exception {
199 >        AtomicReferenceArray x = new AtomicReferenceArray(SIZE);
200 >        for (int i = 0; i < SIZE; i++) {
201 >            x.set(i, new Integer(-i));
202 >        }
203 >        AtomicReferenceArray y = serialClone(x);
204 >        assertNotSame(x, y);
205 >        assertEquals(x.length(), y.length());
206 >        for (int i = 0; i < SIZE; i++) {
207 >            assertEquals(x.get(i), y.get(i));
208 >        }
209 >    }
210 >
211 >    /**
212 >     * toString returns current value.
213 >     */
214 >    public void testToString() {
215 >        Integer[] a = { two, one, three, four, seven };
216 >        AtomicReferenceArray<Integer> aa = new AtomicReferenceArray<Integer>(a);
217 >        assertEquals(Arrays.toString(a), aa.toString());
218      }
100
219   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines