我正在查看java.uti.concurrent.locks.AbstractQueuedSynchronizer的源代码,而acquire()方法看起来像这样 -
public final void acquire(int arg) {
if (!tryAcquire(arg) &&
acquireQueued(addWaiter(Node.EXCLUSIVE), arg))
Thread.currentThread().interrupt();
}
为什么它会中断调用acquire()的线程?如果在线程run()方法的某处检查过,那么它可能在调用acquire()之后传递,这可能是不可取的并且没有考虑过?
任何人都想清楚为什么上面这段代码会这样做?
发布于 2019-03-27 09:01:33
如果您阅读了Javadoc acquiredQueued
,您会注意到如果线程在等待时被中断,它将返回true。因此,调用selfInterrupt
(因为它在OpenJDK源代码中调用)是将中断传播到调用线程,否则将被吞没。
https://stackoverflow.com/questions/-100001056
复制相似问题