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


相关文章
|
23天前
|
Java 调度
[Java]线程生命周期与线程通信
本文详细探讨了线程生命周期与线程通信。文章首先分析了线程的五个基本状态及其转换过程,结合JDK1.8版本的特点进行了深入讲解。接着,通过多个实例介绍了线程通信的几种实现方式,包括使用`volatile`关键字、`Object`类的`wait()`和`notify()`方法、`CountDownLatch`、`ReentrantLock`结合`Condition`以及`LockSupport`等工具。全文旨在帮助读者理解线程管理的核心概念和技术细节。
35 1
[Java]线程生命周期与线程通信
|
9天前
|
Java
JAVA多线程通信:为何wait()与notify()如此重要?
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是实现线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件满足时被唤醒,从而确保数据一致性和同步。相比其他通信方式,如忙等待,这些方法更高效灵活。 示例代码展示了如何在生产者-消费者模型中使用这些方法实现线程间的协调和同步。
24 3
|
24天前
|
安全 Java
Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧
【10月更文挑战第20天】Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧,包括避免在循环外调用wait()、优先使用notifyAll()、确保线程安全及处理InterruptedException等,帮助读者更好地掌握这些方法的应用。
16 1
|
24天前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
34 1
|
24天前
|
Java
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件成立时被唤醒,从而有效解决数据一致性和同步问题。本文通过对比其他通信机制,展示了 `wait()` 和 `notify()` 的优势,并通过生产者-消费者模型的示例代码,详细说明了其使用方法和重要性。
25 1
|
1月前
|
Java
|
1月前
|
Java C++
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
33 0
|
2月前
|
存储 缓存 安全
【Java面试题汇总】多线程、JUC、锁篇(2023版)
线程和进程的区别、CAS的ABA问题、AQS、哪些地方使用了CAS、怎么保证线程安全、线程同步方式、synchronized的用法及原理、Lock、volatile、线程的六个状态、ThreadLocal、线程通信方式、创建方式、两种创建线程池的方法、线程池设置合适的线程数、线程安全的集合?ConcurrentHashMap、JUC
【Java面试题汇总】多线程、JUC、锁篇(2023版)
|
1月前
多线程通信和同步的方式有哪些?
【10月更文挑战第6天】
95 0
|
2月前
|
安全 Java 调度
python3多线程实战(python3经典编程案例)
该文章提供了Python3中多线程的应用实例,展示了如何利用Python的threading模块来创建和管理线程,以实现并发执行任务。
42 0

热门文章

最新文章

相关实验场景

更多