1.Semaphore是java并发编程中的一个计数信号类,可以看作是synchronized 的加强版,其可以控制线程数量。
2.Semaphore主要操作为初始化,添加线程,减少线程:
初始化:其中n表示Semaphore对象开始存储的信号数;
Semaphore semaphore = new Semaphore(n);
添加信号:其中n表示Semaphore对象添加的信号数,n表示为1时可省略;
semaphore.release(n);
减少信号:其中n表示Semaphore对象减少的信号数,n表示为1时可省略,若剩余信号小于n,则当前线程等待,直到信号数达标(不小于n)。
semaphore.acquire(n);
3.例题:转自leetcode(1117.H2O生成)
现在有两种线程,氧 oxygen 和氢 hydrogen,你的目标是组织这两种线程来产生水分子。在一个屏障(barrier)使得每个线程必须等候直到一个完整水分子能够被产生出来。氢和氧线程会被分别给予 releaseHydrogen 和 releaseOxygen 方法来允许它们突破屏障。这些线程应该三三成组突破屏障并能立即组合产生一个水分子。
你必须保证产生一个水分子所需线程的结合必须发生在下一个水分子产生之前。
换句话说: 如果一个氧线程到达屏障时没有氢线程到达,它必须等候直到两个氢线程到达。如果一个氢线程到达屏障时没有其它线程到达,它必须等候直到一个氧线程和另一个氢线程到达。
书写满足这些限制条件的氢、氧线程同步代码。
class H2O {
private Semaphore h = new Semaphore(2);//开始设立h元素和o元素信号都为2(每一个h线程都会影响o信号)
private Semaphore o = new Semaphore(2);
public H2O() {
}
public void hydrogen(Runnable releaseHydrogen) throws InterruptedException {//h线程使得h信号-1,o信号+1
h.acquire();
// releaseHydrogen.run() outputs "H". Do not change or remove this line.
releaseHydrogen.run();
o.release();
}
public void oxygen(Runnable releaseOxygen) throws InterruptedException {//o线程使得h信号+2,o信号-2
o.acquire(2);
// releaseOxygen.run() outputs "H". Do not change or remove this line.
releaseOxygen.run();
h.release(2);
}
}
版权声明:本文为duyduy原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。