三个线程交替打印ABC100次问题思考之二,使用信号量的优雅实现

2023-02-01 14:50:33 浏览数 (1)

如题:使用信号量的优雅实现

方法三:使用SemaphoretryAcquire()方法实现线程间的加锁操作
代码语言: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();
    }
}

使用SemaphoretryAcquire()方法实现线程间的加锁操作,通过release()方法给下一个待执行线程的信号量添加一个许可证,由此保证三个线程顺序执行,初始化A线程信号量时添加一个默认许可证,让A线程第一个执行

上述方法,通过jucSemaphore类能够比较优雅的达成线程间顺序唤醒,也是笔者认为最优雅的方式,有兴趣可以查看上篇文章比较三种方式实现优缺点 三个线程交替打印ABC100次问题思考

0 人点赞