线程池中 work 为何要实现 AbstractQueuedSynchronizer

Worker(Runnable firstTask) {
    setState(-1); // inhibit interrupts until runWorker
    this.firstTask = firstTask;
    this.thread = getThreadFactory().newThread(this);
}


protected boolean tryAcquire(int unused) {
    if (compareAndSetState(0, 1)) {
        setExclusiveOwnerThread(Thread.currentThread());
        return true;
    }
    return false;
}

protected boolean tryRelease(int unused) {
    setExclusiveOwnerThread(null);
    setState(0);
    return true;
}

public void lock()        { acquire(1); }
public boolean tryLock()  { return tryAcquire(1); }
public void unlock()      { release(1); }
public boolean isLocked() { return isHeldExclusively(); }

Worker使用这个锁从队列中获取任务时加锁，每个线程同时只执行一个任务，不需要重入锁（如果是重入锁，就有可能同一个线程同时执行多个任务）
其次在Work运行时

w.lock的目的如果task代码实现里有Thread.sleep或者join等，那就会被中断，task运行没完成，此时新的任务故还不能开始，所以用锁锁住

注意 runWorker方法中刚开始会进行解锁，是由于解锁会将 state设置为0，代表此线程已经开始工作了，为什么要将state 设置为0 因为新建Worker时将state设置为了-1

顺便说一下：

void interruptIfStarted() {
    Thread t;
    if (getState() >= 0 && (t = thread) != null && !t.isInterrupted()) {
        try {
            t.interrupt();
        } catch (SecurityException ignore) {
        }
    }
}
线程池中线程中断 代表只会中断 worker是否已经开始运作（新建work时会将状态设置为 -1）

线程池中 work 为何要实现 AbstractQueuedSynchronizer

推荐阅读