JUC学习(四):线程间定制化通信(案例实现:每个线程打印指定次数)

简介: JUC学习(四):线程间定制化通信(案例实现:每个线程打印指定次数)

A 线程打印 5 次 A,B 线程打印 10 次 B,C 线程打印 15 次 C,按照此顺序循环 10 轮。

     

我们的思路是定义一个标志flag,当flag==1时,线程1打印A;当flag==B时,线程2打印B;当flag==C时,打印C。


/**
 *
 * A 线程打印 5 次 A,B 线程打印 10 次 B,C 线程打印 15 次 C,按照此顺序循环 10 轮
 */
class ShareSource{
    int flag = 1;
    private Lock lock = new ReentrantLock();
    //创建三个condition,一个condition本质上是绑定一个锁
    Condition c1 = lock.newCondition();
    Condition c2 = lock.newCondition();
    Condition c3 = lock.newCondition();
    //打印5次A
    public void print5(int loop) throws InterruptedException {
        lock.lock();
        try {
            while(flag!=1){
                c1.await();
            }
            for (int i = 1; i <= loop; i++) {
                System.out.println(Thread.currentThread().getName()+"打印出:A,当前为第"+i+"轮");
            }
            flag = 2;   //修改标志位
            c2.signal();    //通知线程B
        } finally {
            lock.unlock();
        }
    }
    public void print10(int loop) throws InterruptedException {
        lock.lock();
        try {
            while (flag!=2){
                c2.await();
            }
            for (int i = 1; i <= loop; i++) {
                System.out.println(Thread.currentThread().getName()+"打印出:B,当前为第"+i+"轮");
            }
            flag = 3;
            c3.signal();
        } finally {
            lock.unlock();
        }
    }
    public void print15(int loop) throws InterruptedException {
        lock.lock();
        try{
            while(flag!=3){
                c3.await();
            }
            for (int i = 1; i <= loop; i++) {
                System.out.println(Thread.currentThread().getName()+"打印出:C,当前为第"+i+"轮");
            }
            flag = 1;
            c1.signal();
        }finally {
            lock.unlock();
        }
    }
}
public class ThreadDemo03 {
    public static void main(String[] args) {
        ShareSource shareSource = new ShareSource();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    shareSource.print5(5);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "线程A").start();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    shareSource.print10(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "线程B").start();
        new Thread(()->{
            for (int i = 0; i < 10; i++) {
                try {
                    shareSource.print15(15);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }, "线程C").start();
    }
}



运行结果:

线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
线程A打印出:A,当前为第1轮
线程A打印出:A,当前为第2轮
线程A打印出:A,当前为第3轮
线程A打印出:A,当前为第4轮
线程A打印出:A,当前为第5轮
线程B打印出:B,当前为第1轮
线程B打印出:B,当前为第2轮
线程B打印出:B,当前为第3轮
线程B打印出:B,当前为第4轮
线程B打印出:B,当前为第5轮
线程B打印出:B,当前为第6轮
线程B打印出:B,当前为第7轮
线程B打印出:B,当前为第8轮
线程B打印出:B,当前为第9轮
线程B打印出:B,当前为第10轮
线程C打印出:C,当前为第1轮
线程C打印出:C,当前为第2轮
线程C打印出:C,当前为第3轮
线程C打印出:C,当前为第4轮
线程C打印出:C,当前为第5轮
线程C打印出:C,当前为第6轮
线程C打印出:C,当前为第7轮
线程C打印出:C,当前为第8轮
线程C打印出:C,当前为第9轮
线程C打印出:C,当前为第10轮
线程C打印出:C,当前为第11轮
线程C打印出:C,当前为第12轮
线程C打印出:C,当前为第13轮
线程C打印出:C,当前为第14轮
线程C打印出:C,当前为第15轮
Process finished with exit code 0


相关文章
|
3月前
|
Java
实现Java多线程中的线程间通信
实现Java多线程中的线程间通信
|
26天前
|
存储 缓存 安全
【Java面试题汇总】多线程、JUC、锁篇(2023版)
线程和进程的区别、CAS的ABA问题、AQS、哪些地方使用了CAS、怎么保证线程安全、线程同步方式、synchronized的用法及原理、Lock、volatile、线程的六个状态、ThreadLocal、线程通信方式、创建方式、两种创建线程池的方法、线程池设置合适的线程数、线程安全的集合?ConcurrentHashMap、JUC
【Java面试题汇总】多线程、JUC、锁篇(2023版)
|
1月前
|
监控 Java 调度
【Java学习】多线程&JUC万字超详解
本文详细介绍了多线程的概念和三种实现方式,还有一些常见的成员方法,CPU的调动方式,多线程的生命周期,还有线程安全问题,锁和死锁的概念,以及等待唤醒机制,阻塞队列,多线程的六种状态,线程池等
108 6
【Java学习】多线程&JUC万字超详解
|
2月前
|
算法 Java
JUC(1)线程和进程、并发和并行、线程的状态、lock锁、生产者和消费者问题
该博客文章综合介绍了Java并发编程的基础知识,包括线程与进程的区别、并发与并行的概念、线程的生命周期状态、`sleep`与`wait`方法的差异、`Lock`接口及其实现类与`synchronized`关键字的对比,以及生产者和消费者问题的解决方案和使用`Condition`对象替代`synchronized`关键字的方法。
JUC(1)线程和进程、并发和并行、线程的状态、lock锁、生产者和消费者问题
|
15天前
|
安全 Java 调度
python3多线程实战(python3经典编程案例)
该文章提供了Python3中多线程的应用实例,展示了如何利用Python的threading模块来创建和管理线程,以实现并发执行任务。
14 0
|
2月前
|
设计模式 Java 调度
JUC线程池: ScheduledThreadPoolExecutor详解
`ScheduledThreadPoolExecutor`是Java标准库提供的一个强大的定时任务调度工具,它让并发编程中的任务调度变得简单而可靠。这个类的设计兼顾了灵活性与功能性,使其成为实现复杂定时任务逻辑的理想选择。不过,使用时仍需留意任务的执行时间以及系统的实际响应能力,以避免潜在的调度问题影响应用程序的行为。
64 1
|
2月前
|
消息中间件 安全 Kafka
"深入实践Kafka多线程Consumer:案例分析、实现方式、优缺点及高效数据处理策略"
【8月更文挑战第10天】Apache Kafka是一款高性能的分布式流处理平台,以高吞吐量和可扩展性著称。为提升数据处理效率,常采用多线程消费Kafka数据。本文通过电商订单系统的案例,探讨了多线程Consumer的实现方法及其利弊,并提供示例代码。案例展示了如何通过并行处理加快订单数据的处理速度,确保数据正确性和顺序性的同时最大化资源利用。多线程Consumer有两种主要模式:每线程一个实例和单实例多worker线程。前者简单易行但资源消耗较大;后者虽能解耦消息获取与处理,却增加了系统复杂度。通过合理设计,多线程Consumer能够有效支持高并发数据处理需求。
94 4
|
2月前
|
Java API 调度
JUC线程池: FutureTask详解
总而言之,FutureTask是Java并发编程中一个非常实用的类,它在异步任务执行及结果处理方面提供了优雅的解决方案。在实现细节方面可以搭配线程池的使用,以及与Callable接口的配合使用,来完成高效的并发任务执行和结果处理。
30 0
|
2月前
|
Java 程序员 容器
【多线程面试题二十四】、 说说你对JUC的了解
这篇文章介绍了Java并发包java.util.concurrent(简称JUC),它是JSR 166规范的实现,提供了并发编程所需的基础组件,包括原子更新类、锁与条件变量、线程池、阻塞队列、并发容器和同步器等多种工具。
|
2月前
|
存储 安全 Java
【多线程面试题 七】、 说一说Java多线程之间的通信方式
Java多线程之间的通信方式主要有:使用Object类的wait()、notify()、notifyAll()方法进行线程间协调;使用Lock接口的Condition的await()、signal()、signalAll()方法实现更灵活的线程间协作;以及使用BlockingQueue作为线程安全的队列来实现生产者和消费者模型的线程通信。