--- jsr166/src/jsr166y/ForkJoinWorkerThread.java	2012/01/26 00:08:13	1.68
+++ jsr166/src/jsr166y/ForkJoinWorkerThread.java	2012/02/20 18:20:06	1.69
@@ -43,8 +43,8 @@ public class ForkJoinWorkerThread extend
         if (ueh != null)
             setUncaughtExceptionHandler(ueh);
         this.pool = pool;
-        this.workQueue = new ForkJoinPool.WorkQueue(this, pool.localMode);
-        pool.registerWorker(this);
+        pool.registerWorker(this.workQueue = new ForkJoinPool.WorkQueue
+                            (pool, this, pool.localMode));
     }
 
     /**
@@ -101,7 +101,7 @@ public class ForkJoinWorkerThread extend
         Throwable exception = null;
         try {
             onStart();
-            pool.runWorker(this);
+            pool.runWorker(workQueue);
         } catch (Throwable ex) {
             exception = ex;
         } finally {