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

Comparing jsr166/src/test/loops/CachedThreadPoolLoops.java (file contents):
Revision 1.6 by jsr166, Tue Mar 15 19:47:05 2011 UTC vs.
Revision 1.10 by jsr166, Sat Dec 31 21:34:47 2016 UTC

# Line 20 | Line 20 | public class CachedThreadPoolLoops {
20  
21          System.out.print("Warmup:");
22          for (int j = 0; j < 1; ++j) {
23 <            int k = 1;
24 <            for (int i = 1; i <= maxThreads;) {
23 >            for (int k = 1, i = 1; i <= maxThreads;) {
24                  System.out.print(" " + i);
25                  oneTest(i, 10000, false);
26                  Thread.sleep(100);
# Line 35 | Line 34 | public class CachedThreadPoolLoops {
34          }
35          System.out.println();
36  
37 <        int k = 1;
39 <        for (int i = 1; i <= maxThreads;) {
37 >        for (int k = 1, i = 1; i <= maxThreads;) {
38              System.out.println("Threads:" + i);
39              oneTest(i, maxIters, true);
40              Thread.sleep(100);
# Line 47 | Line 45 | public class CachedThreadPoolLoops {
45              else
46                  i = k;
47          }
48 <   }
48 >    }
49  
50      static void oneTest(int nThreads, int iters, boolean print) throws Exception {
51          Thread.sleep(100); // System.gc();
# Line 77 | Line 75 | public class CachedThreadPoolLoops {
75          Thread.sleep(100); // System.gc();
76          if (print) System.out.print("ArrayBlockingQueue(256) ");
77          oneRun(new ArrayBlockingQueue<Runnable>(256), nThreads, iters, print);
80 –
78      }
79  
80      static final class Task implements Runnable {
# Line 134 | Line 131 | public class CachedThreadPoolLoops {
131      static final class LTQasSQ<T> extends LinkedTransferQueue<T> {
132          LTQasSQ() { super(); }
133          public void put(T x) {
134 <            try { super.transfer(x);
135 <            } catch (InterruptedException ex) { throw new Error(); }
134 >            try { super.transfer(x); }
135 >            catch (InterruptedException ex) { throw new Error(ex); }
136          }
137      }
138  
# Line 146 | Line 143 | public class CachedThreadPoolLoops {
143              if ((++calls & 1) == 0)
144                  super.put(x);
145              else {
146 <                try { super.transfer(x);
147 <                } catch (InterruptedException ex) {
151 <                    throw new Error();
152 <                }
146 >                try { super.transfer(x); }
147 >                catch (InterruptedException ex) { throw new Error(ex); }
148              }
149          }
150      }

Diff Legend

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