# | Line 43 | Line 43 | public class ForkJoinWorkerThread extend | |
---|---|---|
43 | if (ueh != null) | |
44 | setUncaughtExceptionHandler(ueh); | |
45 | this.pool = pool; | |
46 | < | this.workQueue = new ForkJoinPool.WorkQueue(this, pool.localMode); |
47 | < | pool.registerWorker(this); |
46 | > | pool.registerWorker(this.workQueue = new ForkJoinPool.WorkQueue |
47 | > | (pool, this, pool.localMode)); |
48 | } | |
49 | ||
50 | /** | |
# | Line 101 | Line 101 | public class ForkJoinWorkerThread extend | |
101 | Throwable exception = null; | |
102 | try { | |
103 | onStart(); | |
104 | < | pool.runWorker(this); |
104 | > | pool.runWorker(workQueue); |
105 | } catch (Throwable ex) { | |
106 | exception = ex; | |
107 | } finally { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |