test/tck/AtomicLongArrayTest.java

/*
 * Written by Doug Lea with assistance from members of JCP JSR-166
 * Expert Group and released to the public domain, as explained at
 * http://creativecommons.org/publicdomain/zero/1.0/
 * Other contributors include Andrew Wright, Jeffrey Hayes,
 * Pat Fisher, Mike Judd.
 */

import java.util.Arrays;
import java.util.concurrent.atomic.AtomicLongArray;

import junit.framework.Test;
import junit.framework.TestSuite;

public class AtomicLongArrayTest extends JSR166TestCase {
    public static void main(String[] args) {
        main(suite(), args);
    }
    public static Test suite() {
        return new TestSuite(AtomicLongArrayTest.class);
    }

    /**
     * constructor creates array of given size with all elements zero
     */
    public void testConstructor() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++)
            assertEquals(0, aa.get(i));
    }

    /**
     * constructor with null array throws NPE
     */
    public void testConstructor2NPE() {
        try {
            long[] a = null;
            new AtomicLongArray(a);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * constructor with array is of same size and has all elements
     */
    public void testConstructor2() {
        long[] a = { 17L, 3L, -42L, 99L, -7L };
        AtomicLongArray aa = new AtomicLongArray(a);
        assertEquals(a.length, aa.length());
        for (int i = 0; i < a.length; i++)
            assertEquals(a[i], aa.get(i));
    }

    /**
     * get and set for out of bound indices throw IndexOutOfBoundsException
     */
    public void testIndexing() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int index : new int[] { -1, SIZE }) {
            try {
                aa.get(index);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.set(index, 1);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.lazySet(index, 1);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.compareAndSet(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.weakCompareAndSet(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.getAndAdd(index, 1);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.addAndGet(index, 1);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.getPlain(index);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.getOpaque(index);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.getAcquire(index);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.setPlain(index, 1);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.setOpaque(index, 1);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.setRelease(index, 1);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.compareAndExchange(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.compareAndExchangeAcquire(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.compareAndExchangeRelease(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.weakCompareAndSetVolatile(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.weakCompareAndSetAcquire(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
            try {
                aa.weakCompareAndSetRelease(index, 1, 2);
                shouldThrow();
            } catch (IndexOutOfBoundsException success) {}
        }
    }

    /**
     * get returns the last value set at index
     */
    public void testGetSet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.get(i));
            aa.set(i, 2);
            assertEquals(2, aa.get(i));
            aa.set(i, -3);
            assertEquals(-3, aa.get(i));
        }
    }

    /**
     * get returns the last value lazySet at index by same thread
     */
    public void testGetLazySet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.lazySet(i, 1);
            assertEquals(1, aa.get(i));
            aa.lazySet(i, 2);
            assertEquals(2, aa.get(i));
            aa.lazySet(i, -3);
            assertEquals(-3, aa.get(i));
        }
    }

    /**
     * compareAndSet succeeds in changing value if equal to expected else fails
     */
    public void testCompareAndSet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertTrue(aa.compareAndSet(i, 1, 2));
            assertTrue(aa.compareAndSet(i, 2, -4));
            assertEquals(-4, aa.get(i));
            assertFalse(aa.compareAndSet(i, -5, 7));
            assertEquals(-4, aa.get(i));
            assertTrue(aa.compareAndSet(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }

    /**
     * compareAndSet in one thread enables another waiting for value
     * to succeed
     */
    public void testCompareAndSetInMultipleThreads() throws InterruptedException {
        final AtomicLongArray a = new AtomicLongArray(1);
        a.set(0, 1);
        Thread t = new Thread(new CheckedRunnable() {
            public void realRun() {
                while (!a.compareAndSet(0, 2, 3))
                    Thread.yield();
            }});

        t.start();
        assertTrue(a.compareAndSet(0, 1, 2));
        t.join(LONG_DELAY_MS);
        assertFalse(t.isAlive());
        assertEquals(3, a.get(0));
    }

    /**
     * repeated weakCompareAndSet succeeds in changing value when equal
     * to expected
     */
    public void testWeakCompareAndSet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            do {} while (!aa.weakCompareAndSet(i, 1, 2));
            do {} while (!aa.weakCompareAndSet(i, 2, -4));
            assertEquals(-4, aa.get(i));
            do {} while (!aa.weakCompareAndSet(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }

    /**
     * getAndSet returns previous value and sets to given value at given index
     */
    public void testGetAndSet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.getAndSet(i, 0));
            assertEquals(0, aa.getAndSet(i, -10));
            assertEquals(-10, aa.getAndSet(i, 1));
        }
    }

    /**
     * getAndAdd returns previous value and adds given value
     */
    public void testGetAndAdd() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.getAndAdd(i, 2));
            assertEquals(3, aa.get(i));
            assertEquals(3, aa.getAndAdd(i, -4));
            assertEquals(-1, aa.get(i));
        }
    }

    /**
     * getAndDecrement returns previous value and decrements
     */
    public void testGetAndDecrement() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.getAndDecrement(i));
            assertEquals(0, aa.getAndDecrement(i));
            assertEquals(-1, aa.getAndDecrement(i));
        }
    }

    /**
     * getAndIncrement returns previous value and increments
     */
    public void testGetAndIncrement() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.getAndIncrement(i));
            assertEquals(2, aa.get(i));
            aa.set(i, -2);
            assertEquals(-2, aa.getAndIncrement(i));
            assertEquals(-1, aa.getAndIncrement(i));
            assertEquals(0, aa.getAndIncrement(i));
            assertEquals(1, aa.get(i));
        }
    }

    /**
     * addAndGet adds given value to current, and returns current value
     */
    public void testAddAndGet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(3, aa.addAndGet(i, 2));
            assertEquals(3, aa.get(i));
            assertEquals(-1, aa.addAndGet(i, -4));
            assertEquals(-1, aa.get(i));
        }
    }

    /**
     * decrementAndGet decrements and returns current value
     */
    public void testDecrementAndGet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(0, aa.decrementAndGet(i));
            assertEquals(-1, aa.decrementAndGet(i));
            assertEquals(-2, aa.decrementAndGet(i));
            assertEquals(-2, aa.get(i));
        }
    }

    /**
     * incrementAndGet increments and returns current value
     */
    public void testIncrementAndGet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(2, aa.incrementAndGet(i));
            assertEquals(2, aa.get(i));
            aa.set(i, -2);
            assertEquals(-1, aa.incrementAndGet(i));
            assertEquals(0, aa.incrementAndGet(i));
            assertEquals(1, aa.incrementAndGet(i));
            assertEquals(1, aa.get(i));
        }
    }

    class Counter extends CheckedRunnable {
        final AtomicLongArray aa;
        volatile long counts;
        Counter(AtomicLongArray a) { aa = a; }
        public void realRun() {
            for (;;) {
                boolean done = true;
                for (int i = 0; i < aa.length(); i++) {
                    long v = aa.get(i);
                    assertTrue(v >= 0);
                    if (v != 0) {
                        done = false;
                        if (aa.compareAndSet(i, v, v - 1))
                            ++counts;
                    }
                }
                if (done)
                    break;
            }
        }
    }

    /**
     * Multiple threads using same array of counters successfully
     * update a number of times equal to total count
     */
    public void testCountingInMultipleThreads() throws InterruptedException {
        final AtomicLongArray aa = new AtomicLongArray(SIZE);
        long countdown = 10000;
        for (int i = 0; i < SIZE; i++)
            aa.set(i, countdown);
        Counter c1 = new Counter(aa);
        Counter c2 = new Counter(aa);
        Thread t1 = new Thread(c1);
        Thread t2 = new Thread(c2);
        t1.start();
        t2.start();
        t1.join();
        t2.join();
        assertEquals(c1.counts+c2.counts, SIZE * countdown);
    }

    /**
     * a deserialized serialized array holds same values
     */
    public void testSerialization() throws Exception {
        AtomicLongArray x = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++)
            x.set(i, -i);
        AtomicLongArray y = serialClone(x);
        assertNotSame(x, y);
        assertEquals(x.length(), y.length());
        for (int i = 0; i < SIZE; i++) {
            assertEquals(x.get(i), y.get(i));
        }
    }

    /**
     * toString returns current value.
     */
    public void testToString() {
        long[] a = { 17, 3, -42, 99, -7 };
        AtomicLongArray aa = new AtomicLongArray(a);
        assertEquals(Arrays.toString(a), aa.toString());
    }

    // jdk9
    
    /**
     * getPlain returns the last value set
     */
    public void testGetPlainSet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.getPlain(i));
            aa.set(i, 2);
            assertEquals(2, aa.getPlain(i));
            aa.set(i, -3);
            assertEquals(-3, aa.getPlain(i));
        }
    }

    /**
     * getOpaque returns the last value set
     */
    public void testGetOpaqueSet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.getOpaque(i));
            aa.set(i, 2);
            assertEquals(2, aa.getOpaque(i));
            aa.set(i, -3);
            assertEquals(-3, aa.getOpaque(i));
        }
    }

    /**
     * getAcquire returns the last value set
     */
    public void testGetAcquireSet() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.getAcquire(i));
            aa.set(i, 2);
            assertEquals(2, aa.getAcquire(i));
            aa.set(i, -3);
            assertEquals(-3, aa.getAcquire(i));
        }
    }

    /**
     * get returns the last value setPlain
     */
    public void testGetSetPlain() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.setPlain(i, 1);
            assertEquals(1, aa.get(i));
            aa.setPlain(i, 2);
            assertEquals(2, aa.get(i));
            aa.setPlain(i, -3);
            assertEquals(-3, aa.get(i));
        }
    }

    /**
     * get returns the last value setOpaque
     */
    public void testGetSetOpaque() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.setOpaque(i, 1);
            assertEquals(1, aa.get(i));
            aa.setOpaque(i, 2);
            assertEquals(2, aa.get(i));
            aa.setOpaque(i, -3);
            assertEquals(-3, aa.get(i));
        }
    }

    /**
     * get returns the last value setRelease
     */
    public void testGetSetRelease() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.setRelease(i, 1);
            assertEquals(1, aa.get(i));
            aa.setRelease(i, 2);
            assertEquals(2, aa.get(i));
            aa.setRelease(i, -3);
            assertEquals(-3, aa.get(i));
        }
    }

    /**
     * compareAndExchange succeeds in changing value if equal to
     * expected else fails
     */
    public void testCompareAndExchange() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.compareAndExchange(i, 1, 2));
            assertEquals(2, aa.compareAndExchange(i, 2, -4));
            assertEquals(-4, aa.get(i));
            assertEquals(-4, aa.compareAndExchange(i,-5, 7));
            assertEquals(-4, aa.get(i));
            assertEquals(-4, aa.compareAndExchange(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }

    /**
     * compareAndExchangeAcquire succeeds in changing value if equal to
     * expected else fails
     */
    public void testCompareAndExchangeAcquire() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.compareAndExchangeAcquire(i, 1, 2));
            assertEquals(2, aa.compareAndExchangeAcquire(i, 2, -4));
            assertEquals(-4, aa.get(i));
            assertEquals(-4, aa.compareAndExchangeAcquire(i,-5, 7));
            assertEquals(-4, aa.get(i));
            assertEquals(-4, aa.compareAndExchangeAcquire(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }

    /**
     * compareAndExchangeRelease succeeds in changing value if equal to
     * expected else fails
     */
    public void testCompareAndExchangeRelease() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            assertEquals(1, aa.compareAndExchangeRelease(i, 1, 2));
            assertEquals(2, aa.compareAndExchangeRelease(i, 2, -4));
            assertEquals(-4, aa.get(i));
            assertEquals(-4, aa.compareAndExchangeRelease(i,-5, 7));
            assertEquals(-4, aa.get(i));
            assertEquals(-4, aa.compareAndExchangeRelease(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }

    /**
     * repeated weakCompareAndSetVolatile succeeds in changing value when equal
     * to expected
     */
    public void testWeakCompareAndSetVolatile() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            do {} while (!aa.weakCompareAndSetVolatile(i, 1, 2));
            do {} while (!aa.weakCompareAndSetVolatile(i, 2, -4));
            assertEquals(-4, aa.get(i));
            do {} while (!aa.weakCompareAndSetVolatile(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }

    /**
     * repeated weakCompareAndSetAcquire succeeds in changing value when equal
     * to expected
     */
    public void testWeakCompareAndSetAcquire() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            do {} while (!aa.weakCompareAndSetAcquire(i, 1, 2));
            do {} while (!aa.weakCompareAndSetAcquire(i, 2, -4));
            assertEquals(-4, aa.get(i));
            do {} while (!aa.weakCompareAndSetAcquire(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }

    /**
     * repeated weakCompareAndSetRelease succeeds in changing value when equal
     * to expected
     */
    public void testWeakCompareAndSetRelease() {
        AtomicLongArray aa = new AtomicLongArray(SIZE);
        for (int i = 0; i < SIZE; i++) {
            aa.set(i, 1);
            do {} while (!aa.weakCompareAndSetRelease(i, 1, 2));
            do {} while (!aa.weakCompareAndSetRelease(i, 2, -4));
            assertEquals(-4, aa.get(i));
            do {} while (!aa.weakCompareAndSetRelease(i, -4, 7));
            assertEquals(7, aa.get(i));
        }
    }
    
}
Revision:	1.33
Committed:	Thu Jun 16 23:35:25 2016 UTC (7 years, 10 months ago) by dl
Branch:	MAIN
Changes since 1.32:	+242 -0 lines
Log Message:	Add VarHandle atomic methods to Atomic classes
#	User	Rev	Content
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.19	* http://creativecommons.org/publicdomain/zero/1.0/
5	jsr166	1.10	* Other contributors include Andrew Wright, Jeffrey Hayes,
6			* Pat Fisher, Mike Judd.
7	dl	1.1	*/
8
9	jsr166	1.21	import java.util.Arrays;
10			import java.util.concurrent.atomic.AtomicLongArray;
11	dl	1.1
12	jsr166	1.28	import junit.framework.Test;
13			import junit.framework.TestSuite;
14
15	dl	1.3	public class AtomicLongArrayTest extends JSR166TestCase {
16	jsr166	1.16	public static void main(String[] args) {
17	jsr166	1.31	main(suite(), args);
18	dl	1.1	}
19			public static Test suite() {
20			return new TestSuite(AtomicLongArrayTest.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	jsr166	1.12	public void testConstructor() {
27	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
28			for (int i = 0; i < SIZE; i++)
29			assertEquals(0, aa.get(i));
30	dl	1.1	}
31
32	dl	1.4	/**
33	dl	1.7	* constructor with null array throws NPE
34			*/
35			public void testConstructor2NPE() {
36			try {
37			long[] a = null;
38	jsr166	1.30	new AtomicLongArray(a);
39	jsr166	1.13	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	jsr166	1.22	long[] a = { 17L, 3L, -42L, 99L, -7L };
48	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(a);
49			assertEquals(a.length, aa.length());
50			for (int i = 0; i < a.length; i++)
51			assertEquals(a[i], aa.get(i));
52	dl	1.7	}
53
54			/**
55	dl	1.5	* get and set for out of bound indices throw IndexOutOfBoundsException
56			*/
57	jsr166	1.12	public void testIndexing() {
58	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
59			for (int index : new int[] { -1, SIZE }) {
60			try {
61			aa.get(index);
62			shouldThrow();
63			} catch (IndexOutOfBoundsException success) {}
64			try {
65			aa.set(index, 1);
66			shouldThrow();
67			} catch (IndexOutOfBoundsException success) {}
68			try {
69			aa.lazySet(index, 1);
70			shouldThrow();
71			} catch (IndexOutOfBoundsException success) {}
72			try {
73			aa.compareAndSet(index, 1, 2);
74			shouldThrow();
75			} catch (IndexOutOfBoundsException success) {}
76			try {
77			aa.weakCompareAndSet(index, 1, 2);
78			shouldThrow();
79			} catch (IndexOutOfBoundsException success) {}
80			try {
81			aa.getAndAdd(index, 1);
82			shouldThrow();
83			} catch (IndexOutOfBoundsException success) {}
84			try {
85			aa.addAndGet(index, 1);
86			shouldThrow();
87			} catch (IndexOutOfBoundsException success) {}
88	dl	1.33	try {
89			aa.getPlain(index);
90			shouldThrow();
91			} catch (IndexOutOfBoundsException success) {}
92			try {
93			aa.getOpaque(index);
94			shouldThrow();
95			} catch (IndexOutOfBoundsException success) {}
96			try {
97			aa.getAcquire(index);
98			shouldThrow();
99			} catch (IndexOutOfBoundsException success) {}
100			try {
101			aa.setPlain(index, 1);
102			shouldThrow();
103			} catch (IndexOutOfBoundsException success) {}
104			try {
105			aa.setOpaque(index, 1);
106			shouldThrow();
107			} catch (IndexOutOfBoundsException success) {}
108			try {
109			aa.setRelease(index, 1);
110			shouldThrow();
111			} catch (IndexOutOfBoundsException success) {}
112			try {
113			aa.compareAndExchange(index, 1, 2);
114			shouldThrow();
115			} catch (IndexOutOfBoundsException success) {}
116			try {
117			aa.compareAndExchangeAcquire(index, 1, 2);
118			shouldThrow();
119			} catch (IndexOutOfBoundsException success) {}
120			try {
121			aa.compareAndExchangeRelease(index, 1, 2);
122			shouldThrow();
123			} catch (IndexOutOfBoundsException success) {}
124			try {
125			aa.weakCompareAndSetVolatile(index, 1, 2);
126			shouldThrow();
127			} catch (IndexOutOfBoundsException success) {}
128			try {
129			aa.weakCompareAndSetAcquire(index, 1, 2);
130			shouldThrow();
131			} catch (IndexOutOfBoundsException success) {}
132			try {
133			aa.weakCompareAndSetRelease(index, 1, 2);
134			shouldThrow();
135			} catch (IndexOutOfBoundsException success) {}
136	dl	1.5	}
137			}
138
139			/**
140			* get returns the last value set at index
141	dl	1.4	*/
142	jsr166	1.12	public void testGetSet() {
143	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
144			for (int i = 0; i < SIZE; i++) {
145			aa.set(i, 1);
146			assertEquals(1, aa.get(i));
147			aa.set(i, 2);
148			assertEquals(2, aa.get(i));
149			aa.set(i, -3);
150			assertEquals(-3, aa.get(i));
151	dl	1.1	}
152			}
153
154	dl	1.4	/**
155	dl	1.9	* get returns the last value lazySet at index by same thread
156			*/
157	jsr166	1.12	public void testGetLazySet() {
158	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
159			for (int i = 0; i < SIZE; i++) {
160			aa.lazySet(i, 1);
161			assertEquals(1, aa.get(i));
162			aa.lazySet(i, 2);
163			assertEquals(2, aa.get(i));
164			aa.lazySet(i, -3);
165			assertEquals(-3, aa.get(i));
166	dl	1.9	}
167			}
168
169			/**
170	dl	1.5	* compareAndSet succeeds in changing value if equal to expected else fails
171	dl	1.4	*/
172	jsr166	1.12	public void testCompareAndSet() {
173	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
174			for (int i = 0; i < SIZE; i++) {
175			aa.set(i, 1);
176			assertTrue(aa.compareAndSet(i, 1, 2));
177			assertTrue(aa.compareAndSet(i, 2, -4));
178			assertEquals(-4, aa.get(i));
179			assertFalse(aa.compareAndSet(i, -5, 7));
180			assertEquals(-4, aa.get(i));
181			assertTrue(aa.compareAndSet(i, -4, 7));
182			assertEquals(7, aa.get(i));
183	dl	1.1	}
184			}
185
186	dl	1.4	/**
187	dl	1.5	* compareAndSet in one thread enables another waiting for value
188			* to succeed
189			*/
190	jsr166	1.13	public void testCompareAndSetInMultipleThreads() throws InterruptedException {
191	dl	1.5	final AtomicLongArray a = new AtomicLongArray(1);
192			a.set(0, 1);
193	jsr166	1.14	Thread t = new Thread(new CheckedRunnable() {
194			public void realRun() {
195			while (!a.compareAndSet(0, 2, 3))
196			Thread.yield();
197			}});
198	jsr166	1.13
199			t.start();
200			assertTrue(a.compareAndSet(0, 1, 2));
201			t.join(LONG_DELAY_MS);
202			assertFalse(t.isAlive());
203	jsr166	1.24	assertEquals(3, a.get(0));
204	dl	1.5	}
205
206			/**
207			* repeated weakCompareAndSet succeeds in changing value when equal
208	jsr166	1.10	* to expected
209	dl	1.4	*/
210	jsr166	1.12	public void testWeakCompareAndSet() {
211	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
212			for (int i = 0; i < SIZE; i++) {
213			aa.set(i, 1);
214	jsr166	1.29	do {} while (!aa.weakCompareAndSet(i, 1, 2));
215			do {} while (!aa.weakCompareAndSet(i, 2, -4));
216	jsr166	1.25	assertEquals(-4, aa.get(i));
217	jsr166	1.29	do {} while (!aa.weakCompareAndSet(i, -4, 7));
218	jsr166	1.25	assertEquals(7, aa.get(i));
219	dl	1.1	}
220			}
221
222	dl	1.4	/**
223	jsr166	1.18	* getAndSet returns previous value and sets to given value at given index
224	dl	1.4	*/
225	jsr166	1.12	public void testGetAndSet() {
226	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
227			for (int i = 0; i < SIZE; i++) {
228			aa.set(i, 1);
229			assertEquals(1, aa.getAndSet(i, 0));
230			assertEquals(0, aa.getAndSet(i, -10));
231			assertEquals(-10, aa.getAndSet(i, 1));
232	dl	1.1	}
233			}
234
235	dl	1.4	/**
236	jsr166	1.18	* getAndAdd returns previous value and adds given value
237	dl	1.4	*/
238	jsr166	1.12	public void testGetAndAdd() {
239	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
240			for (int i = 0; i < SIZE; i++) {
241			aa.set(i, 1);
242			assertEquals(1, aa.getAndAdd(i, 2));
243			assertEquals(3, aa.get(i));
244			assertEquals(3, aa.getAndAdd(i, -4));
245			assertEquals(-1, aa.get(i));
246	dl	1.1	}
247			}
248
249	dl	1.4	/**
250	dl	1.5	* getAndDecrement returns previous value and decrements
251	dl	1.4	*/
252	jsr166	1.12	public void testGetAndDecrement() {
253	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
254			for (int i = 0; i < SIZE; i++) {
255			aa.set(i, 1);
256			assertEquals(1, aa.getAndDecrement(i));
257			assertEquals(0, aa.getAndDecrement(i));
258			assertEquals(-1, aa.getAndDecrement(i));
259	dl	1.1	}
260			}
261
262	dl	1.4	/**
263	dl	1.5	* getAndIncrement returns previous value and increments
264	dl	1.4	*/
265	jsr166	1.12	public void testGetAndIncrement() {
266	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
267			for (int i = 0; i < SIZE; i++) {
268			aa.set(i, 1);
269			assertEquals(1, aa.getAndIncrement(i));
270			assertEquals(2, aa.get(i));
271			aa.set(i, -2);
272			assertEquals(-2, aa.getAndIncrement(i));
273			assertEquals(-1, aa.getAndIncrement(i));
274			assertEquals(0, aa.getAndIncrement(i));
275			assertEquals(1, aa.get(i));
276	dl	1.1	}
277			}
278
279	dl	1.4	/**
280	jsr166	1.18	* addAndGet adds given value to current, and returns current value
281	dl	1.4	*/
282	dl	1.1	public void testAddAndGet() {
283	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
284			for (int i = 0; i < SIZE; i++) {
285			aa.set(i, 1);
286			assertEquals(3, aa.addAndGet(i, 2));
287			assertEquals(3, aa.get(i));
288			assertEquals(-1, aa.addAndGet(i, -4));
289			assertEquals(-1, aa.get(i));
290	dl	1.1	}
291			}
292
293	dl	1.4	/**
294	dl	1.5	* decrementAndGet decrements and returns current value
295	dl	1.4	*/
296	jsr166	1.12	public void testDecrementAndGet() {
297	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
298			for (int i = 0; i < SIZE; i++) {
299			aa.set(i, 1);
300			assertEquals(0, aa.decrementAndGet(i));
301			assertEquals(-1, aa.decrementAndGet(i));
302			assertEquals(-2, aa.decrementAndGet(i));
303			assertEquals(-2, aa.get(i));
304	dl	1.1	}
305			}
306
307	dl	1.4	/**
308	dl	1.5	* incrementAndGet increments and returns current value
309	dl	1.4	*/
310	dl	1.1	public void testIncrementAndGet() {
311	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(SIZE);
312			for (int i = 0; i < SIZE; i++) {
313			aa.set(i, 1);
314			assertEquals(2, aa.incrementAndGet(i));
315			assertEquals(2, aa.get(i));
316			aa.set(i, -2);
317			assertEquals(-1, aa.incrementAndGet(i));
318			assertEquals(0, aa.incrementAndGet(i));
319			assertEquals(1, aa.incrementAndGet(i));
320			assertEquals(1, aa.get(i));
321	dl	1.1	}
322			}
323	dl	1.2
324	jsr166	1.17	class Counter extends CheckedRunnable {
325	jsr166	1.25	final AtomicLongArray aa;
326	dl	1.3	volatile long counts;
327	jsr166	1.25	Counter(AtomicLongArray a) { aa = a; }
328	jsr166	1.17	public void realRun() {
329	dl	1.3	for (;;) {
330			boolean done = true;
331	jsr166	1.25	for (int i = 0; i < aa.length(); i++) {
332			long v = aa.get(i);
333	jsr166	1.17	assertTrue(v >= 0);
334	dl	1.3	if (v != 0) {
335			done = false;
336	jsr166	1.32	if (aa.compareAndSet(i, v, v - 1))
337	dl	1.3	++counts;
338			}
339			}
340			if (done)
341			break;
342			}
343			}
344			}
345
346	dl	1.4	/**
347	dl	1.5	* Multiple threads using same array of counters successfully
348			* update a number of times equal to total count
349	dl	1.4	*/
350	jsr166	1.13	public void testCountingInMultipleThreads() throws InterruptedException {
351	jsr166	1.25	final AtomicLongArray aa = new AtomicLongArray(SIZE);
352	jsr166	1.27	long countdown = 10000;
353	jsr166	1.25	for (int i = 0; i < SIZE; i++)
354	jsr166	1.27	aa.set(i, countdown);
355	jsr166	1.25	Counter c1 = new Counter(aa);
356			Counter c2 = new Counter(aa);
357	jsr166	1.13	Thread t1 = new Thread(c1);
358			Thread t2 = new Thread(c2);
359			t1.start();
360			t2.start();
361			t1.join();
362			t2.join();
363	jsr166	1.27	assertEquals(c1.counts+c2.counts, SIZE * countdown);
364	dl	1.3	}
365
366	dl	1.4	/**
367	dl	1.5	* a deserialized serialized array holds same values
368	dl	1.4	*/
369	jsr166	1.13	public void testSerialization() throws Exception {
370	jsr166	1.21	AtomicLongArray x = new AtomicLongArray(SIZE);
371	jsr166	1.25	for (int i = 0; i < SIZE; i++)
372	jsr166	1.21	x.set(i, -i);
373			AtomicLongArray y = serialClone(x);
374	jsr166	1.26	assertNotSame(x, y);
375	jsr166	1.21	assertEquals(x.length(), y.length());
376	jsr166	1.25	for (int i = 0; i < SIZE; i++) {
377	jsr166	1.21	assertEquals(x.get(i), y.get(i));
378	dl	1.2	}
379	dl	1.8	}
380
381			/**
382			* toString returns current value.
383	jsr166	1.10	*/
384	dl	1.8	public void testToString() {
385	jsr166	1.22	long[] a = { 17, 3, -42, 99, -7 };
386	jsr166	1.25	AtomicLongArray aa = new AtomicLongArray(a);
387			assertEquals(Arrays.toString(a), aa.toString());
388	dl	1.2	}
389
390	dl	1.33	// jdk9
391
392			/**
393			* getPlain returns the last value set
394			*/
395			public void testGetPlainSet() {
396			AtomicLongArray aa = new AtomicLongArray(SIZE);
397			for (int i = 0; i < SIZE; i++) {
398			aa.set(i, 1);
399			assertEquals(1, aa.getPlain(i));
400			aa.set(i, 2);
401			assertEquals(2, aa.getPlain(i));
402			aa.set(i, -3);
403			assertEquals(-3, aa.getPlain(i));
404			}
405			}
406
407			/**
408			* getOpaque returns the last value set
409			*/
410			public void testGetOpaqueSet() {
411			AtomicLongArray aa = new AtomicLongArray(SIZE);
412			for (int i = 0; i < SIZE; i++) {
413			aa.set(i, 1);
414			assertEquals(1, aa.getOpaque(i));
415			aa.set(i, 2);
416			assertEquals(2, aa.getOpaque(i));
417			aa.set(i, -3);
418			assertEquals(-3, aa.getOpaque(i));
419			}
420			}
421
422			/**
423			* getAcquire returns the last value set
424			*/
425			public void testGetAcquireSet() {
426			AtomicLongArray aa = new AtomicLongArray(SIZE);
427			for (int i = 0; i < SIZE; i++) {
428			aa.set(i, 1);
429			assertEquals(1, aa.getAcquire(i));
430			aa.set(i, 2);
431			assertEquals(2, aa.getAcquire(i));
432			aa.set(i, -3);
433			assertEquals(-3, aa.getAcquire(i));
434			}
435			}
436
437			/**
438			* get returns the last value setPlain
439			*/
440			public void testGetSetPlain() {
441			AtomicLongArray aa = new AtomicLongArray(SIZE);
442			for (int i = 0; i < SIZE; i++) {
443			aa.setPlain(i, 1);
444			assertEquals(1, aa.get(i));
445			aa.setPlain(i, 2);
446			assertEquals(2, aa.get(i));
447			aa.setPlain(i, -3);
448			assertEquals(-3, aa.get(i));
449			}
450			}
451
452			/**
453			* get returns the last value setOpaque
454			*/
455			public void testGetSetOpaque() {
456			AtomicLongArray aa = new AtomicLongArray(SIZE);
457			for (int i = 0; i < SIZE; i++) {
458			aa.setOpaque(i, 1);
459			assertEquals(1, aa.get(i));
460			aa.setOpaque(i, 2);
461			assertEquals(2, aa.get(i));
462			aa.setOpaque(i, -3);
463			assertEquals(-3, aa.get(i));
464			}
465			}
466
467			/**
468			* get returns the last value setRelease
469			*/
470			public void testGetSetRelease() {
471			AtomicLongArray aa = new AtomicLongArray(SIZE);
472			for (int i = 0; i < SIZE; i++) {
473			aa.setRelease(i, 1);
474			assertEquals(1, aa.get(i));
475			aa.setRelease(i, 2);
476			assertEquals(2, aa.get(i));
477			aa.setRelease(i, -3);
478			assertEquals(-3, aa.get(i));
479			}
480			}
481
482			/**
483			* compareAndExchange succeeds in changing value if equal to
484			* expected else fails
485			*/
486			public void testCompareAndExchange() {
487			AtomicLongArray aa = new AtomicLongArray(SIZE);
488			for (int i = 0; i < SIZE; i++) {
489			aa.set(i, 1);
490			assertEquals(1, aa.compareAndExchange(i, 1, 2));
491			assertEquals(2, aa.compareAndExchange(i, 2, -4));
492			assertEquals(-4, aa.get(i));
493			assertEquals(-4, aa.compareAndExchange(i,-5, 7));
494			assertEquals(-4, aa.get(i));
495			assertEquals(-4, aa.compareAndExchange(i, -4, 7));
496			assertEquals(7, aa.get(i));
497			}
498			}
499
500			/**
501			* compareAndExchangeAcquire succeeds in changing value if equal to
502			* expected else fails
503			*/
504			public void testCompareAndExchangeAcquire() {
505			AtomicLongArray aa = new AtomicLongArray(SIZE);
506			for (int i = 0; i < SIZE; i++) {
507			aa.set(i, 1);
508			assertEquals(1, aa.compareAndExchangeAcquire(i, 1, 2));
509			assertEquals(2, aa.compareAndExchangeAcquire(i, 2, -4));
510			assertEquals(-4, aa.get(i));
511			assertEquals(-4, aa.compareAndExchangeAcquire(i,-5, 7));
512			assertEquals(-4, aa.get(i));
513			assertEquals(-4, aa.compareAndExchangeAcquire(i, -4, 7));
514			assertEquals(7, aa.get(i));
515			}
516			}
517
518			/**
519			* compareAndExchangeRelease succeeds in changing value if equal to
520			* expected else fails
521			*/
522			public void testCompareAndExchangeRelease() {
523			AtomicLongArray aa = new AtomicLongArray(SIZE);
524			for (int i = 0; i < SIZE; i++) {
525			aa.set(i, 1);
526			assertEquals(1, aa.compareAndExchangeRelease(i, 1, 2));
527			assertEquals(2, aa.compareAndExchangeRelease(i, 2, -4));
528			assertEquals(-4, aa.get(i));
529			assertEquals(-4, aa.compareAndExchangeRelease(i,-5, 7));
530			assertEquals(-4, aa.get(i));
531			assertEquals(-4, aa.compareAndExchangeRelease(i, -4, 7));
532			assertEquals(7, aa.get(i));
533			}
534			}
535
536			/**
537			* repeated weakCompareAndSetVolatile succeeds in changing value when equal
538			* to expected
539			*/
540			public void testWeakCompareAndSetVolatile() {
541			AtomicLongArray aa = new AtomicLongArray(SIZE);
542			for (int i = 0; i < SIZE; i++) {
543			aa.set(i, 1);
544			do {} while (!aa.weakCompareAndSetVolatile(i, 1, 2));
545			do {} while (!aa.weakCompareAndSetVolatile(i, 2, -4));
546			assertEquals(-4, aa.get(i));
547			do {} while (!aa.weakCompareAndSetVolatile(i, -4, 7));
548			assertEquals(7, aa.get(i));
549			}
550			}
551
552			/**
553			* repeated weakCompareAndSetAcquire succeeds in changing value when equal
554			* to expected
555			*/
556			public void testWeakCompareAndSetAcquire() {
557			AtomicLongArray aa = new AtomicLongArray(SIZE);
558			for (int i = 0; i < SIZE; i++) {
559			aa.set(i, 1);
560			do {} while (!aa.weakCompareAndSetAcquire(i, 1, 2));
561			do {} while (!aa.weakCompareAndSetAcquire(i, 2, -4));
562			assertEquals(-4, aa.get(i));
563			do {} while (!aa.weakCompareAndSetAcquire(i, -4, 7));
564			assertEquals(7, aa.get(i));
565			}
566			}
567
568			/**
569			* repeated weakCompareAndSetRelease succeeds in changing value when equal
570			* to expected
571			*/
572			public void testWeakCompareAndSetRelease() {
573			AtomicLongArray aa = new AtomicLongArray(SIZE);
574			for (int i = 0; i < SIZE; i++) {
575			aa.set(i, 1);
576			do {} while (!aa.weakCompareAndSetRelease(i, 1, 2));
577			do {} while (!aa.weakCompareAndSetRelease(i, 2, -4));
578			assertEquals(-4, aa.get(i));
579			do {} while (!aa.weakCompareAndSetRelease(i, -4, 7));
580			assertEquals(7, aa.get(i));
581			}
582			}
583
584	dl	1.1	}