面试算法题:三线程循环打印ABC

2024-09-01 12:38

本文主要是介绍面试算法题:三线程循环打印ABC,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

面试遇到三线程循环打印ABC的题目,当时没写出来,然后经过查阅,进行整理了一下。

1、题目

有A、B、C 三个线程,A线程 输出“A”,B线程 输出“B”,C线程 输出“C”,要求同时启动3个线程,按照顺序输出“ABC”,循环10次,请使用代码实现。

2、问题分析

  1. A、B、C 三个线程;这表示我们要使用多线程同步,有人说了这不废话吗。是的,笔者只是想说,多线程的实现,有几种方式,①继承Thread,②实现Runnable 接口、③实现Cannable接口
  2. A线程 输出“A”,B线程 输出“B”,C线程 输出“C”:这意味着,3个线程之间的执行体run()不同,要想打印的字符串不同有两种方式;
    • ① 采用静态方式,直接打印
      • 这种方式,显然,需要3个不同的执行体,也就意味着,我们要实现三个不同的线程类,即3个Class
    • ②采用构造器参数动态传递方式,将要打印ABC 分别作为参数变量传递进来打印
      • 这种方式,只需要1个共同的执行体,也就是只需要实现一个线程类,即1个Class
  3. 按照顺序输出“ABC”:这表示,我们要控制线程的顺序,控制线程的顺序有哪些?
    • 采用共享标识 ,对循环的序号进行控制,如:循环总数 %3 的余数,来指定应该对应的哪一个线程
    • 采用互斥锁 :①synchronized和Obejct的wait()、notify,②ReentrantLock和Condition类await 、signal
    • 采用原子类型变量 :如,AtomicInteger
  4. 循环打印10次:这说明,我们需要定义一个线程共享变量static int currentCount,这里不用volatile,是因为volatile,声明变量值的一致性;static声明变量的唯一性。这里需要的是循环打印,是有序的,所以该使用static才对

3、解题方案

网上有各种解题方案,我们一一分析一下

1> 通过线程独有属性来指定线程

采用线程的独有变量,或使指定其名字,通过switch或者if 判读 循环变量。代码如下:

public class Test extends Thread {private static int currentCount = 0;public Test(String name) {this.setName(name);}@Overridepublic void run() {while (currentCount < 30) {switch (currentCount % 3) {//通过currentCount%3的余数控制线程打印A、B、C的顺序case 0://System.out.println("0:"+currentCount+"-");		1if ("A".equals(value)) {System.out.print(value);currentCount++;}break;case 1://System.out.println("0:"+currentCount+"-");		2if ("B".equals(value)) {System.out.print(value);currentCount++;}break;case 2://System.out.println("0:"+currentCount+"-");		3if ("C".equals(value)) {System.out.print(value);currentCount++;}break;}}}public static void main(String[] args) {new Test("A").start();new Test("B").start();new Test("C").start();}
}

这种方式,其实3个线程并不是只执行了30次,它还有很多次并没有打印,不信,你可以将1,2,3处注释取消。

那问题来了,为什么最后是打印了10次循环呢?这是由于currentCount++ 只执行了30次,每执行一次currentCount++ ,必定只能打印一个字符,且currentCount 是一个自增长,那么ABC的顺序也是固定的。因此能打印出来正确的结果。但这种方式并不符合多线程的要求,因此不可取。

如果要想只执行 30 次, 那么需要对循环体进行加锁,以此来控制 count 的增长顺序。
如下:

class demo implements Runnable {private static int count = 1;private String lock = "abc";@Overridepublic void run() {synchronized (lock) {while (count < 30) {switch (count % 3) {case 1:System.out.printf("A");break;case 2:System.out.printf("B");break;case 0:System.out.printf("C");break;}count++;}}}
}
public class Test {public static void main(String[] args) {Thread t1 = new Thread(new demo());Thread t2 = new Thread(new demo());Thread t3 = new Thread(new demo());t1.start();t2.start();t3.start();}
}

2> 使用Synchronized和wait/notifyAll

public class Test {public static void main(String[] args) {new MyThread(0,"A").start();new MyThread(1,"B").start();new MyThread(2,"C").start();}
}
class MyThread extends Thread {private static int currentCount; // 线程共有,判断所有的打印状态private static Object obj = new Object(); // 线程锁对象private int flag; // 0:打印A;1:打印B;2:打印Cprivate String value; public MyThread(int flag,String value) {this.flag = flag;this.value=value;}@Overridepublic void run() {for (int i = 0; i < 10; i++) {synchronized (obj) {while (currentCount % 3 != flag) {try {obj.wait();} catch (InterruptedException e) {e.printStackTrace();}}System.out.print(value); // 执行到这里,表明满足条件,打印currentCount++;obj.notifyAll(); // 调用notifyAll方法}}}
}

3> 使用Lock和await/signalAll

此方式便是将上面代码中的synchronized 的锁机制替换为lock锁,如下:

public class Test {public static void main(String[] args) {new MyThread(0, "A").start();new MyThread(1, "B").start();new MyThread(2, "C").start();}
}class MyThread extends Thread {private static int currentCount; // 线程共有,判断所有的打印状态private static Lock lock = new ReentrantLock(); // 线程共有,线程锁对象private static Condition condition = lock.newCondition();private int flag; // 0:打印A;1:打印B;2:打印Cprivate String value;public MyThread(int flag, String value) {this.flag = flag;this.value = value;}@Overridepublic void run() {for (int i = 0; i < 10; i++) {lock.lock();while (currentCount % 3 != flag) {try {condition.await();} catch (InterruptedException e) {e.printStackTrace();}}System.out.print(value); // 执行到这里,表明满足条件,打印currentCount++;condition.signalAll();lock.unlock();}}
}

以上代码采用的是一样是使用同一对象锁的方式。

这篇关于面试算法题:三线程循环打印ABC的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1126966

相关文章

C# foreach 循环中获取索引的实现方式

《C#foreach循环中获取索引的实现方式》:本文主要介绍C#foreach循环中获取索引的实现方式,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录一、手动维护索引变量二、LINQ Select + 元组解构三、扩展方法封装索引四、使用 for 循环替代

Java程序进程起来了但是不打印日志的原因分析

《Java程序进程起来了但是不打印日志的原因分析》:本文主要介绍Java程序进程起来了但是不打印日志的原因分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java程序进程起来了但是不打印日志的原因1、日志配置问题2、日志文件权限问题3、日志文件路径问题4、程序

springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法

《springboot整合阿里云百炼DeepSeek实现sse流式打印的操作方法》:本文主要介绍springboot整合阿里云百炼DeepSeek实现sse流式打印,本文给大家介绍的非常详细,对大... 目录1.开通阿里云百炼,获取到key2.新建SpringBoot项目3.工具类4.启动类5.测试类6.测

数据库面试必备之MySQL中的乐观锁与悲观锁

《数据库面试必备之MySQL中的乐观锁与悲观锁》:本文主要介绍数据库面试必备之MySQL中乐观锁与悲观锁的相关资料,乐观锁适用于读多写少的场景,通过版本号检查避免冲突,而悲观锁适用于写多读少且对数... 目录一、引言二、乐观锁(一)原理(二)应用场景(三)示例代码三、悲观锁(一)原理(二)应用场景(三)示例

Spring Boot循环依赖原理、解决方案与最佳实践(全解析)

《SpringBoot循环依赖原理、解决方案与最佳实践(全解析)》循环依赖指两个或多个Bean相互直接或间接引用,形成闭环依赖关系,:本文主要介绍SpringBoot循环依赖原理、解决方案与最... 目录一、循环依赖的本质与危害1.1 什么是循环依赖?1.2 核心危害二、Spring的三级缓存机制2.1 三

openCV中KNN算法的实现

《openCV中KNN算法的实现》KNN算法是一种简单且常用的分类算法,本文主要介绍了openCV中KNN算法的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的... 目录KNN算法流程使用OpenCV实现KNNOpenCV 是一个开源的跨平台计算机视觉库,它提供了各

springboot+dubbo实现时间轮算法

《springboot+dubbo实现时间轮算法》时间轮是一种高效利用线程资源进行批量化调度的算法,本文主要介绍了springboot+dubbo实现时间轮算法,文中通过示例代码介绍的非常详细,对大家... 目录前言一、参数说明二、具体实现1、HashedwheelTimer2、createWheel3、n

springboot循环依赖问题案例代码及解决办法

《springboot循环依赖问题案例代码及解决办法》在SpringBoot中,如果两个或多个Bean之间存在循环依赖(即BeanA依赖BeanB,而BeanB又依赖BeanA),会导致Spring的... 目录1. 什么是循环依赖?2. 循环依赖的场景案例3. 解决循环依赖的常见方法方法 1:使用 @La

SpringBoot实现MD5加盐算法的示例代码

《SpringBoot实现MD5加盐算法的示例代码》加盐算法是一种用于增强密码安全性的技术,本文主要介绍了SpringBoot实现MD5加盐算法的示例代码,文中通过示例代码介绍的非常详细,对大家的学习... 目录一、什么是加盐算法二、如何实现加盐算法2.1 加盐算法代码实现2.2 注册页面中进行密码加盐2.

Java时间轮调度算法的代码实现

《Java时间轮调度算法的代码实现》时间轮是一种高效的定时调度算法,主要用于管理延时任务或周期性任务,它通过一个环形数组(时间轮)和指针来实现,将大量定时任务分摊到固定的时间槽中,极大地降低了时间复杂... 目录1、简述2、时间轮的原理3. 时间轮的实现步骤3.1 定义时间槽3.2 定义时间轮3.3 使用时