ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/loops/CachedThreadPoolLoops.java

Comparing jsr166/src/test/loops/CachedThreadPoolLoops.java (file contents):
Revision 1.8 by jsr166, Thu Dec 18 18:13:06 2014 UTC vs.
Revision 1.10 by jsr166, Sat Dec 31 21:34:47 2016 UTC

#	Line 75 | 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);
78	–
78		}
79
80		static final class Task implements Runnable {
#	Line 132 | 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 144 | 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) {
149	<	throw new Error();
150	<	}
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