# | 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; |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |