coo*_*eze 2 java synchronization semaphore
我正在阅读有关信号量的内容,在代码示例中,它使我感到困惑,为什么当代码在最终调用的方法周围使用同步时,为什么使用信号量。这不是在做同样的事情,即一次限制一个线程来执行变异吗?
class Pool {
private static final int MAX_AVAILABLE = 100;
private final Semaphore available = new Semaphore(MAX_AVAILABLE, true);
public Object getItem() throws InterruptedException {
available.acquire();
return getNextAvailableItem();
}
public void putItem(Object x) {
if (markAsUnused(x))
available.release();
}
// Not a particularly efficient data structure; just for demo
protected Object[] items = ... whatever kinds of items being managed
protected boolean[] used = new boolean[MAX_AVAILABLE];
protected synchronized Object getNextAvailableItem() {
for (int i = 0; i < MAX_AVAILABLE; ++i) {
if (!used[i]) {
used[i] = true;
return items[i];
}
}
return null; // not reached
}
protected synchronized boolean markAsUnused(Object item) {
for (int i = 0; i < MAX_AVAILABLE; ++i) {
if (item == items[i]) {
if (used[i]) {
used[i] = false;
return true;
} else
return false;
}
}
return false;
}
}
Run Code Online (Sandbox Code Playgroud)
我指的是对getItem()的调用,该调用先调用Acquisition(),然后再调用getNextAvailableItem,但是无论如何都是同步的。
我想念什么?
参考:http : //docs.oracle.com/javase/8/docs/api/java/util/concurrent/Semaphore.html
信号量和同步块正在完成两个不同的工作。
当它访问和更改项目数组时,synced关键字将保护getNextAvailableItem()。如果一次不限于一个线程,则该操作将损坏。
信号量将允许最多100个线程通过,明显多于1个线程。此代码示例中的目的是在池为空时阻止对池中对象的请求,然后在对象返回到池中时取消阻止一个线程。池。没有信号灯,一切就好像它们正在工作,直到池为空。那时,请求线程不会阻塞并等待对象返回,而是会收到null。