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

Comparing jsr166/src/test/tck/AtomicIntegerTest.java (file contents):
Revision 1.2 by dl, Sun Sep 7 20:39:11 2003 UTC vs.
Revision 1.18 by jsr166, Sun Nov 22 18:55:56 2009 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/licenses/publicdomain
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.*;
11   import java.io.*;
12  
13 < public class AtomicIntegerTest extends TestCase {
13 > public class AtomicIntegerTest extends JSR166TestCase {
14      public static void main (String[] args) {
15          junit.textui.TestRunner.run (suite());
16      }
# Line 17 | Line 18 | public class AtomicIntegerTest extends T
18          return new TestSuite(AtomicIntegerTest.class);
19      }
20  
21 <    public void testConstructor(){
22 <        AtomicInteger ai = new AtomicInteger(1);
23 <        assertEquals(1,ai.get());
24 <    }
25 <
26 <    public void testConstructor2(){
21 >    final int[] VALUES = {
22 >        Integer.MIN_VALUE, -1, 0, 1, 42, Integer.MAX_VALUE,
23 >    };
24 >
25 >    /**
26 >     * constructor initializes to given value
27 >     */
28 >    public void testConstructor() {
29 >        AtomicInteger ai = new AtomicInteger(1);
30 >        assertEquals(1,ai.get());
31 >    }
32 >
33 >    /**
34 >     * default constructed initializes to zero
35 >     */
36 >    public void testConstructor2() {
37          AtomicInteger ai = new AtomicInteger();
38 <        assertEquals(0,ai.get());
28 <    }
29 <
30 <    public void testGetSet(){
31 <        AtomicInteger ai = new AtomicInteger(1);
32 <        assertEquals(1,ai.get());
33 <        ai.set(2);
34 <        assertEquals(2,ai.get());
35 <        ai.set(-3);
36 <        assertEquals(-3,ai.get());
37 <        
38 <    }
39 <    public void testCompareAndSet(){
40 <        AtomicInteger ai = new AtomicInteger(1);
41 <        assertTrue(ai.compareAndSet(1,2));
42 <        assertTrue(ai.compareAndSet(2,-4));
43 <        assertEquals(-4,ai.get());
44 <        assertFalse(ai.compareAndSet(-5,7));
45 <        assertFalse((7 == ai.get()));
46 <        assertTrue(ai.compareAndSet(-4,7));
47 <        assertEquals(7,ai.get());
48 <    }
49 <
50 <    public void testWeakCompareAndSet(){
51 <        AtomicInteger ai = new AtomicInteger(1);
52 <        while(!ai.weakCompareAndSet(1,2));
53 <        while(!ai.weakCompareAndSet(2,-4));
54 <        assertEquals(-4,ai.get());
55 <        while(!ai.weakCompareAndSet(-4,7));
56 <        assertEquals(7,ai.get());
57 <    }
58 <
59 <    public void testGetAndSet(){
60 <        AtomicInteger ai = new AtomicInteger(1);
61 <        assertEquals(1,ai.getAndSet(0));
62 <        assertEquals(0,ai.getAndSet(-10));
63 <        assertEquals(-10,ai.getAndSet(1));
38 >        assertEquals(0,ai.get());
39      }
40  
41 <    public void testGetAndAdd(){
42 <        AtomicInteger ai = new AtomicInteger(1);
43 <        assertEquals(1,ai.getAndAdd(2));
44 <        assertEquals(3,ai.get());
45 <        assertEquals(3,ai.getAndAdd(-4));
46 <        assertEquals(-1,ai.get());
47 <    }
48 <
49 <    public void testGetAndDecrement(){
50 <        AtomicInteger ai = new AtomicInteger(1);
51 <        assertEquals(1,ai.getAndDecrement());
52 <        assertEquals(0,ai.getAndDecrement());
53 <        assertEquals(-1,ai.getAndDecrement());
54 <    }
41 >    /**
42 >     * get returns the last value set
43 >     */
44 >    public void testGetSet() {
45 >        AtomicInteger ai = new AtomicInteger(1);
46 >        assertEquals(1,ai.get());
47 >        ai.set(2);
48 >        assertEquals(2,ai.get());
49 >        ai.set(-3);
50 >        assertEquals(-3,ai.get());
51 >
52 >    }
53 >
54 >    /**
55 >     * get returns the last value lazySet in same thread
56 >     */
57 >    public void testGetLazySet() {
58 >        AtomicInteger ai = new AtomicInteger(1);
59 >        assertEquals(1,ai.get());
60 >        ai.lazySet(2);
61 >        assertEquals(2,ai.get());
62 >        ai.lazySet(-3);
63 >        assertEquals(-3,ai.get());
64 >
65 >    }
66 >    /**
67 >     * compareAndSet succeeds in changing value if equal to expected else fails
68 >     */
69 >    public void testCompareAndSet() {
70 >        AtomicInteger ai = new AtomicInteger(1);
71 >        assertTrue(ai.compareAndSet(1,2));
72 >        assertTrue(ai.compareAndSet(2,-4));
73 >        assertEquals(-4,ai.get());
74 >        assertFalse(ai.compareAndSet(-5,7));
75 >        assertFalse((7 == ai.get()));
76 >        assertTrue(ai.compareAndSet(-4,7));
77 >        assertEquals(7,ai.get());
78 >    }
79 >
80 >    /**
81 >     * compareAndSet in one thread enables another waiting for value
82 >     * to succeed
83 >     */
84 >    public void testCompareAndSetInMultipleThreads() throws Exception {
85 >        final AtomicInteger ai = new AtomicInteger(1);
86 >        Thread t = new Thread(new CheckedRunnable() {
87 >            public void realRun() {
88 >                while (!ai.compareAndSet(2, 3))
89 >                    Thread.yield();
90 >            }});
91 >
92 >        t.start();
93 >        assertTrue(ai.compareAndSet(1, 2));
94 >        t.join(LONG_DELAY_MS);
95 >        assertFalse(t.isAlive());
96 >        assertEquals(ai.get(), 3);
97 >    }
98 >
99 >    /**
100 >     * repeated weakCompareAndSet succeeds in changing value when equal
101 >     * to expected
102 >     */
103 >    public void testWeakCompareAndSet() {
104 >        AtomicInteger ai = new AtomicInteger(1);
105 >        while (!ai.weakCompareAndSet(1,2));
106 >        while (!ai.weakCompareAndSet(2,-4));
107 >        assertEquals(-4,ai.get());
108 >        while (!ai.weakCompareAndSet(-4,7));
109 >        assertEquals(7,ai.get());
110 >    }
111 >
112 >    /**
113 >     * getAndSet returns previous value and sets to given value
114 >     */
115 >    public void testGetAndSet() {
116 >        AtomicInteger ai = new AtomicInteger(1);
117 >        assertEquals(1,ai.getAndSet(0));
118 >        assertEquals(0,ai.getAndSet(-10));
119 >        assertEquals(-10,ai.getAndSet(1));
120 >    }
121 >
122 >    /**
123 >     * getAndAdd returns previous value and adds given value
124 >     */
125 >    public void testGetAndAdd() {
126 >        AtomicInteger ai = new AtomicInteger(1);
127 >        assertEquals(1,ai.getAndAdd(2));
128 >        assertEquals(3,ai.get());
129 >        assertEquals(3,ai.getAndAdd(-4));
130 >        assertEquals(-1,ai.get());
131 >    }
132 >
133 >    /**
134 >     * getAndDecrement returns previous value and decrements
135 >     */
136 >    public void testGetAndDecrement() {
137 >        AtomicInteger ai = new AtomicInteger(1);
138 >        assertEquals(1,ai.getAndDecrement());
139 >        assertEquals(0,ai.getAndDecrement());
140 >        assertEquals(-1,ai.getAndDecrement());
141 >    }
142 >
143 >    /**
144 >     * getAndIncrement returns previous value and increments
145 >     */
146 >    public void testGetAndIncrement() {
147 >        AtomicInteger ai = new AtomicInteger(1);
148 >        assertEquals(1,ai.getAndIncrement());
149 >        assertEquals(2,ai.get());
150 >        ai.set(-2);
151 >        assertEquals(-2,ai.getAndIncrement());
152 >        assertEquals(-1,ai.getAndIncrement());
153 >        assertEquals(0,ai.getAndIncrement());
154 >        assertEquals(1,ai.get());
155 >    }
156 >
157 >    /**
158 >     * addAndGet adds given value to current, and returns current value
159 >     */
160 >    public void testAddAndGet() {
161 >        AtomicInteger ai = new AtomicInteger(1);
162 >        assertEquals(3,ai.addAndGet(2));
163 >        assertEquals(3,ai.get());
164 >        assertEquals(-1,ai.addAndGet(-4));
165 >        assertEquals(-1,ai.get());
166 >    }
167 >
168 >    /**
169 >     * decrementAndGet decrements and returns current value
170 >     */
171 >    public void testDecrementAndGet() {
172 >        AtomicInteger ai = new AtomicInteger(1);
173 >        assertEquals(0,ai.decrementAndGet());
174 >        assertEquals(-1,ai.decrementAndGet());
175 >        assertEquals(-2,ai.decrementAndGet());
176 >        assertEquals(-2,ai.get());
177 >    }
178 >
179 >    /**
180 >     * incrementAndGet increments and returns current value
181 >     */
182 >    public void testIncrementAndGet() {
183 >        AtomicInteger ai = new AtomicInteger(1);
184 >        assertEquals(2,ai.incrementAndGet());
185 >        assertEquals(2,ai.get());
186 >        ai.set(-2);
187 >        assertEquals(-1,ai.incrementAndGet());
188 >        assertEquals(0,ai.incrementAndGet());
189 >        assertEquals(1,ai.incrementAndGet());
190 >        assertEquals(1,ai.get());
191 >    }
192 >
193 >    /**
194 >     * a deserialized serialized atomic holds same value
195 >     */
196 >    public void testSerialization() throws Exception {
197 >        AtomicInteger l = new AtomicInteger();
198  
199 <    public void testGetAndIncrement(){
200 <        AtomicInteger ai = new AtomicInteger(1);
201 <        assertEquals(1,ai.getAndIncrement());
202 <        assertEquals(2,ai.get());
203 <        ai.set(-2);
204 <        assertEquals(-2,ai.getAndIncrement());
205 <        assertEquals(-1,ai.getAndIncrement());
206 <        assertEquals(0,ai.getAndIncrement());
207 <        assertEquals(1,ai.get());
199 >        l.set(22);
200 >        ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
201 >        ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
202 >        out.writeObject(l);
203 >        out.close();
204 >
205 >        ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
206 >        ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
207 >        AtomicInteger r = (AtomicInteger) in.readObject();
208 >        assertEquals(l.get(), r.get());
209 >    }
210 >
211 >    /**
212 >     * toString returns current value.
213 >     */
214 >    public void testToString() {
215 >        AtomicInteger ai = new AtomicInteger();
216 >        assertEquals("0", ai.toString());
217 >        for (int x : VALUES) {
218 >            ai.set(x);
219 >            assertEquals(ai.toString(), Integer.toString(x));
220 >        }
221      }
222  
223 <    public void testAddAndGet(){
224 <        AtomicInteger ai = new AtomicInteger(1);
225 <        assertEquals(3,ai.addAndGet(2));
226 <        assertEquals(3,ai.get());
227 <        assertEquals(-1,ai.addAndGet(-4));
228 <        assertEquals(-1,ai.get());
223 >    /**
224 >     * intValue returns current value.
225 >     */
226 >    public void testIntValue() {
227 >        AtomicInteger ai = new AtomicInteger();
228 >        assertEquals(0, ai.intValue());
229 >        for (int x : VALUES) {
230 >            ai.set(x);
231 >            assertEquals(x, ai.intValue());
232 >        }
233      }
234  
235 <    public void testDecrementAndGet(){
236 <        AtomicInteger ai = new AtomicInteger(1);
237 <        assertEquals(0,ai.decrementAndGet());
238 <        assertEquals(-1,ai.decrementAndGet());
239 <        assertEquals(-2,ai.decrementAndGet());
240 <        assertEquals(-2,ai.get());
235 >    /**
236 >     * longValue returns current value.
237 >     */
238 >    public void testLongValue() {
239 >        AtomicInteger ai = new AtomicInteger();
240 >        assertEquals(0L, ai.longValue());
241 >        for (int x : VALUES) {
242 >            ai.set(x);
243 >            assertEquals((long)x, ai.longValue());
244 >        }
245      }
246  
247 <    public void testIncrementAndGet(){
248 <        AtomicInteger ai = new AtomicInteger(1);
249 <        assertEquals(2,ai.incrementAndGet());
250 <        assertEquals(2,ai.get());
251 <        ai.set(-2);
252 <        assertEquals(-1,ai.incrementAndGet());
253 <        assertEquals(0,ai.incrementAndGet());
254 <        assertEquals(1,ai.incrementAndGet());
255 <        assertEquals(1,ai.get());
247 >    /**
248 >     * floatValue returns current value.
249 >     */
250 >    public void testFloatValue() {
251 >        AtomicInteger ai = new AtomicInteger();
252 >        assertEquals(0.0f, ai.floatValue());
253 >        for (int x : VALUES) {
254 >            ai.set(x);
255 >            assertEquals((float)x, ai.floatValue());
256 >        }
257      }
258  
259 <    public void testSerialization() {
260 <        AtomicInteger l = new AtomicInteger();
261 <
262 <        try {
263 <            l.set(22);
264 <            ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
265 <            ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
266 <            out.writeObject(l);
267 <            out.close();
128 <
129 <            ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
130 <            ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
131 <            AtomicInteger r = (AtomicInteger) in.readObject();
132 <            assertEquals(l.get(), r.get());
133 <        } catch(Exception e){
134 <            e.printStackTrace();
135 <            fail("unexpected exception");
259 >    /**
260 >     * doubleValue returns current value.
261 >     */
262 >    public void testDoubleValue() {
263 >        AtomicInteger ai = new AtomicInteger();
264 >        assertEquals(0.0d, ai.doubleValue());
265 >        for (int x : VALUES) {
266 >            ai.set(x);
267 >            assertEquals((double)x, ai.doubleValue());
268          }
269      }
270  
139
271   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines