线程池中 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使用这个锁从队列中获取任务时加锁，每个线程同时只执行一个任务，不需要重入锁（如果是重入锁，就有可能同一个线程同时执行多个任务）

顺便说一下 ：

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

线程池中 work 为何要实现 AbstractQueuedSynchronizer

原文：https://www.cnblogs.com/shujiying/p/12436867.html