test/tck/CyclicBarrierTest.java

/*
 * Written by members of JCP JSR-166 Expert Group and released to the
 * public domain. Use, modify, and redistribute this code in any way
 * without acknowledgement. Other contributors include Andrew Wright,
 * Jeffrey Hayes, Pat Fischer, Mike Judd.
 */

import junit.framework.*;
import java.util.*;
import java.util.concurrent.*;

public class CyclicBarrierTest extends JSR166TestCase{
    public static void main(String[] args) {
        junit.textui.TestRunner.run (suite());  
    }
    public static Test suite() {
        return new TestSuite(CyclicBarrierTest.class);
    }

    private volatile int countAction;
    private class MyAction implements Runnable {
        public void run() { ++countAction; }
    }
    
    /**
     * Creating with negative parties throws IAE
     */
    public void testConstructor1() {
        try {
            new CyclicBarrier(-1, (Runnable)null);
            shouldThrow();
        } catch(IllegalArgumentException e){}
    }

    /**
     * Creating with negative parties and no action throws IAE
     */
    public void testConstructor2() {
        try {
            new CyclicBarrier(-1);
            shouldThrow();
        } catch(IllegalArgumentException e){}
    }

    /**
     * getParties returns the number of parties given in constructor
     */
    public void testGetParties() {
        CyclicBarrier b = new CyclicBarrier(2);
        assertEquals(2, b.getParties());
        assertEquals(0, b.getNumberWaiting());
    }

    /**
     * A 1-party barrier triggers properly
     */
    public void testSingleParty() {
        try {
            CyclicBarrier b = new CyclicBarrier(1);
            assertEquals(1, b.getParties());
            assertEquals(0, b.getNumberWaiting());
            b.await();
            b.await();
            assertEquals(0, b.getNumberWaiting());
        }
        catch(Exception e) {
            unexpectedException();
        }
    }
    
    /**
     * The supplied barrier action is run at barrier
     */
    public void testBarrierAction() {
        try {
            countAction = 0;
            CyclicBarrier b = new CyclicBarrier(1, new MyAction());
            assertEquals(1, b.getParties());
            assertEquals(0, b.getNumberWaiting());
            b.await();
            b.await();
            assertEquals(0, b.getNumberWaiting());
            assertEquals(countAction, 2);
        }
        catch(Exception e) {
            unexpectedException();
        }
    }

    /**
     * A 2-party/thread barrier triggers properly
     */
    public void testTwoParties() {
        final CyclicBarrier b = new CyclicBarrier(2);
        Thread t = new Thread(new Runnable() {
                public void run() {
                    try {
                        b.await();
                        b.await();
                        b.await();
                        b.await();
                    } catch(Exception e){
                        threadUnexpectedException();
                    }}});

        try {
            t.start();
            b.await();
            b.await();
            b.await();
            b.await();
            t.join();
        } catch(Exception e){
            unexpectedException();
        }
    }


    /**
     * An interruption in one party causes others waiting in await to
     * throw BrokenBarrierException
     */
    public void testAwait1_Interrupted_BrokenBarrier() {
        final CyclicBarrier c = new CyclicBarrier(3);
        Thread t1 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await();
                        threadShouldThrow();
                    } catch(InterruptedException success){}                
                    catch(Exception b){
                        threadUnexpectedException();
                    }
                }
            });
        Thread t2 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await();
                        threadShouldThrow();                        
                    } catch(BrokenBarrierException success){
                    } catch(Exception i){
                        threadUnexpectedException();
                    }
                }
            });
        try {
            t1.start();
            t2.start();
            Thread.sleep(SHORT_DELAY_MS);
            t1.interrupt();
            t1.join(); 
            t2.join();
        } catch(InterruptedException e){
            unexpectedException();
        }
    }

    /**
     * An interruption in one party causes others waiting in timed await to
     * throw BrokenBarrierException
     */
    public void testAwait2_Interrupted_BrokenBarrier() {
      final CyclicBarrier c = new CyclicBarrier(3);
        Thread t1 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await(MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS);
                        threadShouldThrow();
                    } catch(InterruptedException success){
                    } catch(Exception b){
                        threadUnexpectedException();
                    }
                }
            });
        Thread t2 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await(MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS);
                        threadShouldThrow();                        
                    } catch(BrokenBarrierException success){
                    } catch(Exception i){
                        threadUnexpectedException();
                    }
                }
            });
        try {
            t1.start();
            t2.start();
            Thread.sleep(SHORT_DELAY_MS);
            t1.interrupt();
            t1.join(); 
            t2.join();
        } catch(InterruptedException e){
            unexpectedException();
        }
    }
    
    /**
     * A timeout in timed await throws TimeoutException
     */
    public void testAwait3_TimeOutException() {
        final CyclicBarrier c = new CyclicBarrier(2);
        Thread t = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await(SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
                        threadShouldThrow();
                    } catch(TimeoutException success){
                    } catch(Exception b){
                        threadUnexpectedException();
                        
                    }
                }
            });
        try {
            t.start();
            t.join(); 
        } catch(InterruptedException e){
            unexpectedException();
        }
    }
    
    /**
     * A reset of an active barrier causes waiting threads to throw
     * BrokenBarrierException
     */
    public void testReset_BrokenBarrier() {
        final CyclicBarrier c = new CyclicBarrier(3);
        Thread t1 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await();
                        threadShouldThrow();
                    } catch(BrokenBarrierException success){}                
                    catch(Exception b){
                        threadUnexpectedException();
                    }
                }
            });
        Thread t2 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await();
                        threadShouldThrow();                        
                    } catch(BrokenBarrierException success){
                    } catch(Exception i){
                        threadUnexpectedException();
                    }
                }
            });
        try {
            t1.start();
            t2.start();
            Thread.sleep(SHORT_DELAY_MS);
            c.reset();
            t1.join(); 
            t2.join();
        } catch(InterruptedException e){
            unexpectedException();
        }
    }

    /**
     * A reset before threads enter barrier does not throw
     * BrokenBarrierException
     */
    public void testReset_NoBrokenBarrier() {
        final CyclicBarrier c = new CyclicBarrier(3);
        Thread t1 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await();
                    } catch(Exception b){
                        threadUnexpectedException();
                    }
                }
            });
        Thread t2 = new Thread(new Runnable() {
                public void run() {
                    try {
                        c.await();
                    } catch(Exception i){
                        threadUnexpectedException();
                    }
                }
            });
        try {
            c.reset();
            t1.start();
            t2.start();
            c.await();
            t1.join(); 
            t2.join();
        } catch(Exception e){
            unexpectedException();
        }
    }

}
Revision:	1.4
Committed:	Thu Sep 25 11:02:41 2003 UTC (20 years, 7 months ago) by dl
Branch:	MAIN
Changes since 1.3:	+93 -16 lines
Log Message:	improve tck javadocs; rename and add a few tests
#	User	Rev	Content
1	dl	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.
6			*/
7
8			import junit.framework.*;
9			import java.util.*;
10			import java.util.concurrent.*;
11
12	dl	1.2	public class CyclicBarrierTest extends JSR166TestCase{
13	dl	1.1	public static void main(String[] args) {
14			junit.textui.TestRunner.run (suite());
15			}
16			public static Test suite() {
17			return new TestSuite(CyclicBarrierTest.class);
18			}
19	dl	1.3
20			private volatile int countAction;
21			private class MyAction implements Runnable {
22			public void run() { ++countAction; }
23			}
24	dl	1.1
25	dl	1.3	/**
26	dl	1.4	* Creating with negative parties throws IAE
27	dl	1.3	*/
28			public void testConstructor1() {
29			try {
30	dl	1.1	new CyclicBarrier(-1, (Runnable)null);
31	dl	1.3	shouldThrow();
32	dl	1.1	} catch(IllegalArgumentException e){}
33			}
34
35	dl	1.3	/**
36	dl	1.4	* Creating with negative parties and no action throws IAE
37	dl	1.3	*/
38			public void testConstructor2() {
39			try {
40	dl	1.1	new CyclicBarrier(-1);
41	dl	1.3	shouldThrow();
42	dl	1.1	} catch(IllegalArgumentException e){}
43			}
44
45	dl	1.3	/**
46	dl	1.4	* getParties returns the number of parties given in constructor
47	dl	1.3	*/
48	dl	1.4	public void testGetParties() {
49	dl	1.1	CyclicBarrier b = new CyclicBarrier(2);
50			assertEquals(2, b.getParties());
51			assertEquals(0, b.getNumberWaiting());
52			}
53
54	dl	1.3	/**
55	dl	1.4	* A 1-party barrier triggers properly
56	dl	1.3	*/
57	dl	1.1	public void testSingleParty() {
58			try {
59			CyclicBarrier b = new CyclicBarrier(1);
60			assertEquals(1, b.getParties());
61			assertEquals(0, b.getNumberWaiting());
62			b.await();
63			b.await();
64			assertEquals(0, b.getNumberWaiting());
65			}
66			catch(Exception e) {
67	dl	1.3	unexpectedException();
68	dl	1.1	}
69			}
70
71	dl	1.3	/**
72	dl	1.4	* The supplied barrier action is run at barrier
73	dl	1.3	*/
74	dl	1.1	public void testBarrierAction() {
75			try {
76			countAction = 0;
77			CyclicBarrier b = new CyclicBarrier(1, new MyAction());
78			assertEquals(1, b.getParties());
79			assertEquals(0, b.getNumberWaiting());
80			b.await();
81			b.await();
82			assertEquals(0, b.getNumberWaiting());
83			assertEquals(countAction, 2);
84			}
85			catch(Exception e) {
86	dl	1.3	unexpectedException();
87	dl	1.1	}
88			}
89
90	dl	1.3	/**
91	dl	1.4	* A 2-party/thread barrier triggers properly
92	dl	1.3	*/
93			public void testTwoParties() {
94	dl	1.1	final CyclicBarrier b = new CyclicBarrier(2);
95			Thread t = new Thread(new Runnable() {
96	dl	1.3	public void run() {
97	dl	1.1	try {
98			b.await();
99			b.await();
100			b.await();
101			b.await();
102			} catch(Exception e){
103	dl	1.3	threadUnexpectedException();
104	dl	1.1	}}});
105
106			try {
107			t.start();
108			b.await();
109			b.await();
110			b.await();
111			b.await();
112			t.join();
113			} catch(Exception e){
114	dl	1.3	unexpectedException();
115	dl	1.1	}
116			}
117
118
119	dl	1.3	/**
120	dl	1.4	* An interruption in one party causes others waiting in await to
121			* throw BrokenBarrierException
122	dl	1.3	*/
123			public void testAwait1_Interrupted_BrokenBarrier() {
124	dl	1.1	final CyclicBarrier c = new CyclicBarrier(3);
125			Thread t1 = new Thread(new Runnable() {
126	dl	1.3	public void run() {
127			try {
128	dl	1.1	c.await();
129	dl	1.3	threadShouldThrow();
130	dl	1.1	} catch(InterruptedException success){}
131			catch(Exception b){
132	dl	1.4	threadUnexpectedException();
133	dl	1.1	}
134			}
135			});
136	dl	1.3	Thread t2 = new Thread(new Runnable() {
137			public void run() {
138			try {
139	dl	1.1	c.await();
140	dl	1.3	threadShouldThrow();
141	dl	1.1	} catch(BrokenBarrierException success){
142			} catch(Exception i){
143	dl	1.4	threadUnexpectedException();
144	dl	1.1	}
145			}
146			});
147			try {
148			t1.start();
149			t2.start();
150			Thread.sleep(SHORT_DELAY_MS);
151			t1.interrupt();
152			t1.join();
153			t2.join();
154			} catch(InterruptedException e){
155	dl	1.3	unexpectedException();
156	dl	1.1	}
157			}
158
159	dl	1.3	/**
160	dl	1.4	* An interruption in one party causes others waiting in timed await to
161			* throw BrokenBarrierException
162	dl	1.3	*/
163			public void testAwait2_Interrupted_BrokenBarrier() {
164	dl	1.1	final CyclicBarrier c = new CyclicBarrier(3);
165			Thread t1 = new Thread(new Runnable() {
166	dl	1.3	public void run() {
167			try {
168	dl	1.1	c.await(MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS);
169	dl	1.3	threadShouldThrow();
170	dl	1.1	} catch(InterruptedException success){
171			} catch(Exception b){
172	dl	1.4	threadUnexpectedException();
173	dl	1.1	}
174			}
175			});
176	dl	1.3	Thread t2 = new Thread(new Runnable() {
177			public void run() {
178			try {
179	dl	1.1	c.await(MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS);
180	dl	1.3	threadShouldThrow();
181	dl	1.1	} catch(BrokenBarrierException success){
182			} catch(Exception i){
183	dl	1.4	threadUnexpectedException();
184	dl	1.1	}
185			}
186			});
187			try {
188			t1.start();
189			t2.start();
190			Thread.sleep(SHORT_DELAY_MS);
191			t1.interrupt();
192			t1.join();
193			t2.join();
194			} catch(InterruptedException e){
195	dl	1.3	unexpectedException();
196	dl	1.1	}
197			}
198
199	dl	1.3	/**
200	dl	1.4	* A timeout in timed await throws TimeoutException
201	dl	1.3	*/
202			public void testAwait3_TimeOutException() {
203	dl	1.1	final CyclicBarrier c = new CyclicBarrier(2);
204			Thread t = new Thread(new Runnable() {
205	dl	1.3	public void run() {
206			try {
207	dl	1.1	c.await(SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
208	dl	1.3	threadShouldThrow();
209	dl	1.1	} catch(TimeoutException success){
210			} catch(Exception b){
211	dl	1.4	threadUnexpectedException();
212	dl	1.1
213			}
214			}
215			});
216			try {
217			t.start();
218			t.join();
219			} catch(InterruptedException e){
220	dl	1.3	unexpectedException();
221	dl	1.1	}
222			}
223
224	dl	1.4	/**
225			* A reset of an active barrier causes waiting threads to throw
226			* BrokenBarrierException
227			*/
228			public void testReset_BrokenBarrier() {
229			final CyclicBarrier c = new CyclicBarrier(3);
230			Thread t1 = new Thread(new Runnable() {
231			public void run() {
232			try {
233			c.await();
234			threadShouldThrow();
235			} catch(BrokenBarrierException success){}
236			catch(Exception b){
237			threadUnexpectedException();
238			}
239			}
240			});
241			Thread t2 = new Thread(new Runnable() {
242			public void run() {
243			try {
244			c.await();
245			threadShouldThrow();
246			} catch(BrokenBarrierException success){
247			} catch(Exception i){
248			threadUnexpectedException();
249			}
250			}
251			});
252			try {
253			t1.start();
254			t2.start();
255			Thread.sleep(SHORT_DELAY_MS);
256			c.reset();
257			t1.join();
258			t2.join();
259			} catch(InterruptedException e){
260			unexpectedException();
261			}
262			}
263
264			/**
265			* A reset before threads enter barrier does not throw
266			* BrokenBarrierException
267			*/
268			public void testReset_NoBrokenBarrier() {
269			final CyclicBarrier c = new CyclicBarrier(3);
270			Thread t1 = new Thread(new Runnable() {
271			public void run() {
272			try {
273			c.await();
274			} catch(Exception b){
275			threadUnexpectedException();
276			}
277			}
278			});
279			Thread t2 = new Thread(new Runnable() {
280			public void run() {
281			try {
282			c.await();
283			} catch(Exception i){
284			threadUnexpectedException();
285			}
286			}
287			});
288			try {
289			c.reset();
290			t1.start();
291			t2.start();
292			c.await();
293			t1.join();
294			t2.join();
295			} catch(Exception e){
296			unexpectedException();
297			}
298			}
299
300	dl	1.1	}