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