# | 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 |