ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/ForkJoinPool.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/ForkJoinPool.java (file contents):
Revision 1.22 by dl, Tue Aug 17 18:31:59 2010 UTC vs.
Revision 1.23 by dl, Wed Aug 18 14:05:51 2010 UTC

# Line 1853 | Line 1853 | public class ForkJoinPool extends Abstra
1853       *   QueueTaker(BlockingQueue<E> q) { this.queue = q; }
1854       *   public boolean block() throws InterruptedException {
1855       *     if (item == null)
1856 <     *       item = queue.take
1856 >     *       item = queue.take();
1857       *     return true;
1858       *   }
1859       *   public boolean isReleasable() {
1860 <     *     return item != null || (item = queue.poll) != null;
1860 >     *     return item != null || (item = queue.poll()) != null;
1861       *   }
1862       *   public E getItem() { // call after pool.managedBlock completes
1863       *     return item;

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines