CountLatch是一种线程控制机制,线程(或多个线程)可以通过在CountLatch对象上调用await()
来阻塞,该对象将在其countDown()
方法被调用多次后释放。
由于我熟悉wait()
和notify()
的线程控制的概念,因此(对我而言)有一个明显的CountLatch实现,如下所示:
private volatile int count; // initialised in constructor
public synchronized void countDown() {
count--;
if(count <= 0) {
notifyAll();
}
}
public synchronized void await() throws InterruptedException {
while(count > 0) {
wait();
}
}
但是,Java 5提供了自己的实现
java.util.concurrent.CountLatch
,它使用从AbstractQueuedSynchronizer
扩展的内部类。private static final class Sync extends AbstractQueuedSynchronizer {
Sync(int count) {
setState(count);
}
int getCount() {
return getState();
}
protected int tryAcquireShared(int acquires) {
return (getState() == 0) ? 1 : -1;
}
protected boolean tryReleaseShared(int releases) {
// Decrement count; signal when transition to zero
for (;;) {
int c = getState();
if (c == 0)
return false;
int nextc = c-1;
if (compareAndSetState(c, nextc))
return nextc == 0;
}
}
}
Java 5 CountLatch本质上是围绕此Sync对象的包装器:
countDown()
调用sync.releaseShared(1)
await()
调用sync.acquireSharedInterruptibly(1)
这种更复杂的方法的优点是什么?
最佳答案
提议的方法和JDK之间的主要区别在于,您使用的是锁,而AbstractQueuedSynchronizer
是无锁的,并且在内部使用Compare-And-Swap,在中等争用条件下提供了更好的性能。
关于java - 使用QueudSynchronizer实现CountLatch有什么好处?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/25807724/