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

Comparing jsr166/src/test/tck/ExchangerTest.java (file contents):
Revision 1.9 by jsr166, Thu Nov 19 01:49:25 2009 UTC vs.
Revision 1.10 by jsr166, Sat Nov 21 02:07:26 2009 UTC

# Line 13 | Line 13 | import java.util.concurrent.*;
13   public class ExchangerTest extends JSR166TestCase {
14  
15      public static void main(String[] args) {
16 <        junit.textui.TestRunner.run (suite());
16 >        junit.textui.TestRunner.run (suite());
17      }
18      public static Test suite() {
19 <        return new TestSuite(ExchangerTest.class);
19 >        return new TestSuite(ExchangerTest.class);
20      }
21  
22      /**
# Line 24 | Line 24 | public class ExchangerTest extends JSR16
24       */
25      public void testExchange() throws InterruptedException {
26          final Exchanger e = new Exchanger();
27 <        Thread t1 = new Thread(new CheckedRunnable() {
27 >        Thread t1 = new Thread(new CheckedRunnable() {
28              public void realRun() throws InterruptedException {
29                  Object v = e.exchange(one);
30                  threadAssertEquals(v, two);
31                  Object w = e.exchange(v);
32                  threadAssertEquals(w, one);
33              }});
34 <        Thread t2 = new Thread(new CheckedRunnable() {
34 >        Thread t2 = new Thread(new CheckedRunnable() {
35              public void realRun() throws InterruptedException {
36                  Object v = e.exchange(two);
37                  threadAssertEquals(v, one);
# Line 50 | Line 50 | public class ExchangerTest extends JSR16
50       */
51      public void testTimedExchange() throws InterruptedException {
52          final Exchanger e = new Exchanger();
53 <        Thread t1 = new Thread(new CheckedRunnable() {
53 >        Thread t1 = new Thread(new CheckedRunnable() {
54              public void realRun() throws Exception {
55                  Object v = e.exchange(one, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
56                  threadAssertEquals(v, two);
57                  Object w = e.exchange(v, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
58                  threadAssertEquals(w, one);
59              }});
60 <        Thread t2 = new Thread(new CheckedRunnable() {
60 >        Thread t2 = new Thread(new CheckedRunnable() {
61              public void realRun() throws Exception {
62                  Object v = e.exchange(two, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
63                  threadAssertEquals(v, one);
# Line 76 | Line 76 | public class ExchangerTest extends JSR16
76       */
77      public void testExchange_InterruptedException() throws InterruptedException {
78          final Exchanger e = new Exchanger();
79 <        Thread t = new Thread(new CheckedInterruptedRunnable() {
79 >        Thread t = new Thread(new CheckedInterruptedRunnable() {
80              public void realRun() throws InterruptedException {
81                  e.exchange(one);
82              }});
# Line 92 | Line 92 | public class ExchangerTest extends JSR16
92       */
93      public void testTimedExchange_InterruptedException() throws InterruptedException {
94          final Exchanger e = new Exchanger();
95 <        Thread t = new Thread(new CheckedInterruptedRunnable() {
95 >        Thread t = new Thread(new CheckedInterruptedRunnable() {
96              public void realRun() throws Exception {
97                  e.exchange(null, MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS);
98              }});
# Line 107 | Line 107 | public class ExchangerTest extends JSR16
107       */
108      public void testExchange_TimeOutException() throws InterruptedException {
109          final Exchanger e = new Exchanger();
110 <        Thread t = new Thread(new CheckedRunnable() {
110 >        Thread t = new Thread(new CheckedRunnable() {
111              public void realRun() throws Exception {
112                  try {
113                      e.exchange(null, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
# Line 124 | Line 124 | public class ExchangerTest extends JSR16
124       */
125      public void testReplacementAfterExchange() throws InterruptedException {
126          final Exchanger e = new Exchanger();
127 <        Thread t1 = new Thread(new CheckedInterruptedRunnable() {
127 >        Thread t1 = new Thread(new CheckedInterruptedRunnable() {
128              public void realRun() throws InterruptedException {
129                  Object v = e.exchange(one);
130                  threadAssertEquals(v, two);
131                  Object w = e.exchange(v);
132              }});
133 <        Thread t2 = new Thread(new CheckedRunnable() {
133 >        Thread t2 = new Thread(new CheckedRunnable() {
134              public void realRun() throws InterruptedException {
135                  Object v = e.exchange(two);
136                  threadAssertEquals(v, one);
# Line 138 | Line 138 | public class ExchangerTest extends JSR16
138                  Object w = e.exchange(v);
139                  threadAssertEquals(w, three);
140              }});
141 <        Thread t3 = new Thread(new CheckedRunnable() {
141 >        Thread t3 = new Thread(new CheckedRunnable() {
142              public void realRun() throws InterruptedException {
143                  Thread.sleep(SMALL_DELAY_MS);
144                  Object w = e.exchange(three);

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines