如题:使用信号量的优雅实现
方法三:使用Semaphore
的tryAcquire()
方法实现线程间的加锁操作
代码语言:javascript复制public class PrintAbcBySemaphore {
/**
* 循环计数初始值0
*/
static int count = 0;
// 定义三个线程对应的信号量A、B、C,默认给A线程一个许可证
private Semaphore semaphoreA = new Semaphore(1);
private Semaphore semaphoreB = new Semaphore(0);
private Semaphore semaphoreC = new Semaphore(0);
public void print() {
Thread threadA = new Thread(() -> {
extracted(semaphoreA, "A", semaphoreB);
});
Thread threadB = new Thread(() -> {
extracted(semaphoreB, "B", semaphoreC);
});
Thread threadC = new Thread(() -> {
extracted(semaphoreC, "C", semaphoreA);
});
threadB.start();
threadC.start();
try {
Thread.sleep(2000L);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
threadA.start();
}
private void extracted(Semaphore needSemaphore, String A, Semaphore nextSemaphore) {
while (true) {
// 当前线程的信号量加锁
if (needSemaphore.tryAcquire(1)) {
if (count < 100) {
System.out.println(A);
count ;
// 给下一个待执行线程的信号量加一个许可证
nextSemaphore.release();
} else {
// 执行100次后,退出线程
nextSemaphore.release();
break;
}
}
}
}
public static void main(String[] args) {
new PrintAbcBySemaphore().print();
}
}
使用Semaphore
的tryAcquire()
方法实现线程间的加锁操作,通过release()
方法给下一个待执行线程的信号量添加一个许可证,由此保证三个线程顺序执行,初始化A线程信号量时添加一个默认许可证,让A线程第一个执行
上述方法,通过juc
的Semaphore
类能够比较优雅的达成线程间顺序唤醒,也是笔者认为最优雅的方式,有兴趣可以查看上篇文章比较三种方式实现优缺点 三个线程交替打印ABC100次问题思考