《java.util.concurrent 包源码阅读》24 Fork/Join框架之Work-Stealing

    private boolean scan(ForkJoinWorkerThread w, int a) {
        // scanGuard是32位的整数，用于worker线程数组的索引
        // 第16位称为SG_UNIT，为1表示锁住
        // 0到15位是mask
        int g = scanGuard;
        // parallelism表示并发数，一般指CPU可以同时运行的线程数
        // 默认值是Runtime类的availableProcessors方法返回值，表示
        // 处理器的数量
        // a是活跃的Worker线程的数量，parallelism是大于0的，因此
        // 条件parallelism == 1 - a满足意味着parallelism为1而a为0
        // 而加上blockedCount为0（意味着没有线程因为join被阻塞），
        // 两个条件同时满足也就意味既没有任何线程在运行，那么也就
        // 意味着没有任务存在于worker线程，所以m=0也就是没法偷任务
        // SMASK=0xffff，g & SMASK返回的值scanGuard的0到15位的数值
        int m = (parallelism == 1 - a && blockedCount == 0) ? 0 : g & SMASK;
        ForkJoinWorkerThread[] ws = workers;
        if (ws == null || ws.length <= m) 
            return false;

        // 
        for (int r = w.seed, k = r, j = -(m + m); j <= m + m; ++j) {
            ForkJoinTask<?> t; ForkJoinTask<?>[] q; int b, i;
            // 从线程队列中随机获取一个worker线程
            ForkJoinWorkerThread v = ws[k & m];
            // 判断Worker线程是否存在以及该线程的任务队列是否有任务
            if (v != null && (b = v.queueBase) != v.queueTop &&
                (q = v.queue) != null && (i = (q.length - 1) & b) >= 0) {
                // 从队列中偷走一个任务
                long u = (i << ASHIFT) + ABASE;
                if ((t = q[i]) != null && v.queueBase == b &&
                    UNSAFE.compareAndSwapObject(q, u, t, null)) {
                    int d = (v.queueBase = b + 1) - v.queueTop;
                    v.stealHint = w.poolIndex;
                    // d是偷走一个任务后任务队列的长度
                    if (d != 0)
                        signalWork();
                    w.execTask(t);
                }
                r ^= r << 13; r ^= r >>> 17; w.seed = r ^ (r << 5);
                // false表示扫描到了任务
                return false;
            }
            else if (j < 0) {                     // 异或移位，更新k
                r ^= r << 13; r ^= r >>> 17; k = r ^= r << 5;
            }
            else
                ++k;
        }

        // 如果扫描不到任务，但是scanGuard被更新了，说明有任务的变化
        if (scanGuard != g)
            return false;
        else {
            // 从线程池的任务队列中取出任务来执行
            ForkJoinTask<?> t; ForkJoinTask<?>[] q; int b, i;
            if ((b = queueBase) != queueTop &&
                (q = submissionQueue) != null &&
                (i = (q.length - 1) & b) >= 0) {
                long u = (i << ASHIFT) + ABASE;
                if ((t = q[i]) != null && queueBase == b &&
                    UNSAFE.compareAndSwapObject(q, u, t, null)) {
                    queueBase = b + 1;
                    w.execTask(t);
                }
                return false;
            }
            return true;
        }
    }