三个线程交替打印ABC100次问题思考

简介: 三个线程交替打印ABC100次问题思考

image.png

如题:使用三个线程交替打印ABC,直至100次代码实战

方法一:使用notify()、wait()方法

public class PrintAbc {
    /**
     * 唤醒线程的状态值 state: threadA = 0, threadB = 1, threadC =2,
     */
    int state = 0;
    /**
     * 循环技术,初始值0
     */
    int count = 0;
    public void print(PrintAbc printAbc) {
        Thread threadA = new Thread(() -> {
            extracted(printAbc, "A", 0, 1);
        });
        Thread threadB = new Thread(() -> {
            extracted(printAbc, "B", 1, 2);
        });
        Thread threadC = new Thread(() -> {
            extracted(printAbc, "C", 2, 0);
        });
        threadC.start();
        threadB.start();
        try {
            Thread.sleep(1000L);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        threadA.start();
    }
    /**
     * 交替打印abc,直至100次
     *
     * @param printAbc  锁对象
     * @param a         打印的字母, 对应A、B、C
     * @param needState 当前线程对应的state状态值
     * @param nextState 唤醒下一个线程所需state状态值
     */
    private void extracted(PrintAbc printAbc, String a, int needState, int nextState) {
        while (true) {
            synchronized (printAbc) {
                if (count >= 100) {
                    break;
                }
                if (printAbc.count < 100 && printAbc.state == needState) {
                    System.out.println(a);
                    printAbc.state = nextState;
                    printAbc.count++;
                    printAbc.notifyAll();
                } else {
                    try {
                        printAbc.wait();
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        }
    }
    public static void main(String[] args) {
        PrintAbc printAbc = new PrintAbc();
        printAbc.print(printAbc);
    }
}

上述代码使用notify(),wait(),进行线程间的条件唤醒,state的初始状态是0,对应线程A,所以第一次打印字母也一定是A

方法二:使用ReentrantLock的Condition条件

public class PrintAbcByCondition {
    /**
     * 循环计数初始值0
     */
    static int count = 0;
    public void print() {
        ReentrantLock reentrantLock = new ReentrantLock();
        Condition conditionA = reentrantLock.newCondition();
        Condition conditionB = reentrantLock.newCondition();
        Condition conditionC = reentrantLock.newCondition();
        Thread threadA = new Thread(() -> {
            while (true) {
                try {
                    reentrantLock.lock();
                    // threadA进来打印A然后唤醒threadB
                    if (count < 100) {
                        System.out.println("A");
                        count++;
                        conditionB.signal();
                    }
                    conditionA.await();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                } finally {
                    reentrantLock.unlock();
                }
            }
        });
        Thread threadB = new Thread(() -> {
            while (true) {
                try {
                    reentrantLock.lock();
                    // threadB进来就阻塞等待threadA使用完毕
                    conditionB.await();
                    if (count < 100) {
                        System.out.println("B");
                        count++;
                        conditionC.signal();
                    }
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                } finally {
                    reentrantLock.unlock();
                }
            }
        });
        Thread threadC = new Thread(() -> {
            while (true) {
                try {
                    reentrantLock.lock();
                    // threadC进来就阻塞等待threadB使用完毕
                    conditionC.await();
                    if (count < 100) {
                        System.out.println("C");
                        count++;
                        conditionA.signal();
                    }
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                } finally {
                    reentrantLock.unlock();
                }
            }
        });
        threadC.start();
        threadB.start();
        try {
            Thread.sleep(1000L);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        threadA.start();
    }
    public static void main(String[] args) {
        new PrintAbcByCondition().print();
    }
}

使用ReentrantLock的Condition条件,很容易能实现三个线程之间的交替打印,需要注意的一点就是线程A是需要第一个执行,可以看到代码里threadA在等待1秒后在执行,也能确保是第一个进行打印,原因如下

线程B和线程C中任意一个线程拿到锁都需要等待条件成立,线程C依赖线程B,而线程B依赖线程A,所以他们会一直阻塞直至线程A执行

上述两个方法中,核心问题就是如何实现线程间的条件唤醒,如方法一,我们可以自定义state状态变量来与各个线程绑定,每个线程都有自己对应的state状态,当state变量当前值与线程自身期望的state值相同才唤醒当前线程。也可以使用jucReentrantLock的提供的Condition条件完成线程间的条件唤醒。

至此,三个线程交替打印ABC100次的实现方法介绍完毕



目录
相关文章
|
8月前
高频面试题:如何分别用三种姿势实现三个线程交替打印0到100
高频面试题:如何分别用三种姿势实现三个线程交替打印0到100
201 0
一个有意思的面试题 → 线程交替输出问题
用两个线程,一个输出数字,一个输出字母,交替输出 1A2B3C4D...26Z
|
8月前
|
消息中间件 移动开发 自然语言处理
多线程知识:三个线程如何交替打印ABC循环100次
synchronized是Java中的一个关键字,用于实现对共享资源的互斥访问。wait和notify是Object类中的两个方法,用于实现线程间的通信。wait方法会让当前线程释放锁,并进入等待状态,直到被其他线程唤醒。notify方法会唤醒一个在同一个锁上等待的线程。
102 1
三个线程交替打印ABC100次问题思考之二,使用信号量的优雅实现
三个线程交替打印ABC100次问题思考之二,使用信号量的优雅实现
88 0
斐讯面试记录—三线程交替打印ABC
斐讯面试记录—三线程交替打印ABC
52 0
一个有意思的面试题 → 线程交替输出问题
问题描述   用两个线程,一个输出数字,一个输出字母,交替输出 1A2B3C4D...26Z
Java老掉牙的面试问题:线程交替打印问题,分析实操一下 下
Java老掉牙的面试问题:线程交替打印问题,分析实操一下 下
|
消息中间件 JavaScript 小程序
Java老掉牙的面试问题:线程交替打印问题,分析实操一下 上
Java老掉牙的面试问题:线程交替打印问题,分析实操一下 上
|
5天前
|
设计模式 安全 Java
Java面试题:设计模式如单例模式、工厂模式、观察者模式等在多线程环境下线程安全问题,Java内存模型定义了线程如何与内存交互,包括原子性、可见性、有序性,并发框架提供了更高层次的并发任务处理能力
Java面试题:设计模式如单例模式、工厂模式、观察者模式等在多线程环境下线程安全问题,Java内存模型定义了线程如何与内存交互,包括原子性、可见性、有序性,并发框架提供了更高层次的并发任务处理能力
18 1