AI 助理
备案控制台
开发者社区 大数据 文章 正文

高并发编程-线程通信_使用wait和notify进行线程间的通信2_多生产者多消费者导致程序假死原因分析

2023-05-27 63
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
日志服务 SLS，月写入数据量 50GB 1个月
简介： 高并发编程-线程通信_使用wait和notify进行线程间的通信2_多生产者多消费者导致程序假死原因分析

20191031000606569.png

概述

高并发编程-线程通信_使用wait和notify进行线程间的通信 - 遗留问题


20191001005010259.png


我们看到了 应用卡住了 。。。。 怀疑是不是死锁呢？ （其实没有）

jstack或者可视化工具检测是否死锁(没有)

C:\Users\Mr.Yang>E:
E:\>cd E:\Program Files\Java\jdk1.8.0_161\bin
E:\Program Files\Java\jdk1.8.0_161\bin>jps
1504 MultiProduceConsumerDemo
E:\Program Files\Java\jdk1.8.0_161\bin>jstack 1504
2019-10-01 00:44:23
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.161-b12 mixed mode):
"DestroyJavaVM" #15 prio=5 os_prio=0 tid=0x0000000002983800 nid=0x3348 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
"Thread-3" #14 prio=5 os_prio=0 tid=0x0000000019fa5000 nid=0x3af0 in Object.wait() [0x000000001abff000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x000000078b682768> (a java.lang.Object)
        at java.lang.Object.wait(Object.java:502)
        at com.artisan.test.MultiProduceConsumerDemo.consume(MultiProduceConsumerDemo.java:42)
        - locked <0x000000078b682768> (a java.lang.Object)
        at com.artisan.test.MultiProduceConsumerDemo$2.run(MultiProduceConsumerDemo.java:63)
"Thread-2" #13 prio=5 os_prio=0 tid=0x0000000019fa4000 nid=0x9e4 in Object.wait() [0x000000001aaff000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x000000078b682768> (a java.lang.Object)
        at java.lang.Object.wait(Object.java:502)
        at com.artisan.test.MultiProduceConsumerDemo.consume(MultiProduceConsumerDemo.java:42)
        - locked <0x000000078b682768> (a java.lang.Object)
        at com.artisan.test.MultiProduceConsumerDemo$2.run(MultiProduceConsumerDemo.java:63)
"Thread-1" #12 prio=5 os_prio=0 tid=0x0000000019fa0000 nid=0x37cc in Object.wait() [0x000000001a9ff000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x000000078b682768> (a java.lang.Object)
        at java.lang.Object.wait(Object.java:502)
        at com.artisan.test.MultiProduceConsumerDemo.produce(MultiProduceConsumerDemo.java:20)
        - locked <0x000000078b682768> (a java.lang.Object)
        at com.artisan.test.MultiProduceConsumerDemo$1.run(MultiProduceConsumerDemo.java:55)
"Thread-0" #11 prio=5 os_prio=0 tid=0x0000000019f9f800 nid=0x1bd4 in Object.wait() [0x000000001a8fe000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x000000078b682768> (a java.lang.Object)
        at java.lang.Object.wait(Object.java:502)
        at com.artisan.test.MultiProduceConsumerDemo.produce(MultiProduceConsumerDemo.java:20)
        - locked <0x000000078b682768> (a java.lang.Object)
        at com.artisan.test.MultiProduceConsumerDemo$1.run(MultiProduceConsumerDemo.java:55)
"Service Thread" #10 daemon prio=9 os_prio=0 tid=0x0000000019d2f800 nid=0x3ba4 runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
"C1 CompilerThread2" #9 daemon prio=9 os_prio=2 tid=0x0000000019ca3800 nid=0x37e4 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
"C2 CompilerThread1" #8 daemon prio=9 os_prio=2 tid=0x0000000019c54800 nid=0x2db0 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
"C2 CompilerThread0" #7 daemon prio=9 os_prio=2 tid=0x0000000019c50800 nid=0x37bc waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
"Monitor Ctrl-Break" #6 daemon prio=5 os_prio=0 tid=0x0000000019c2e000 nid=0x2ed4 runnable [0x000000001a2fe000]
   java.lang.Thread.State: RUNNABLE
        at java.net.SocketInputStream.socketRead0(Native Method)
        at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
        at java.net.SocketInputStream.read(SocketInputStream.java:171)
        at java.net.SocketInputStream.read(SocketInputStream.java:141)
        at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
        at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
        at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
        - locked <0x000000078b5dad50> (a java.io.InputStreamReader)
        at java.io.InputStreamReader.read(InputStreamReader.java:184)
        at java.io.BufferedReader.fill(BufferedReader.java:161)
        at java.io.BufferedReader.readLine(BufferedReader.java:324)
        - locked <0x000000078b5dad50> (a java.io.InputStreamReader)
        at java.io.BufferedReader.readLine(BufferedReader.java:389)
        at com.intellij.rt.execution.application.AppMainV2$1.run(AppMainV2.java:64)
"Attach Listener" #5 daemon prio=5 os_prio=2 tid=0x0000000018860000 nid=0x34f8 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
"Signal Dispatcher" #4 daemon prio=9 os_prio=2 tid=0x0000000019c08800 nid=0x1514 runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE
"Finalizer" #3 daemon prio=8 os_prio=1 tid=0x000000001883a000 nid=0x22c in Object.wait() [0x0000000019b9e000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x000000078b408ec0> (a java.lang.ref.ReferenceQueue$Lock)
        at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)
        - locked <0x000000078b408ec0> (a java.lang.ref.ReferenceQueue$Lock)
        at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
        at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)
"Reference Handler" #2 daemon prio=10 os_prio=2 tid=0x0000000002a73800 nid=0x29bc in Object.wait() [0x0000000019a9f000]
   java.lang.Thread.State: WAITING (on object monitor)
        at java.lang.Object.wait(Native Method)
        - waiting on <0x000000078b406b68> (a java.lang.ref.Reference$Lock)
        at java.lang.Object.wait(Object.java:502)
        at java.lang.ref.Reference.tryHandlePending(Reference.java:191)
        - locked <0x000000078b406b68> (a java.lang.ref.Reference$Lock)
        at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)
"VM Thread" os_prio=2 tid=0x0000000018818000 nid=0x381c runnable
"GC task thread#0 (ParallelGC)" os_prio=0 tid=0x0000000002998000 nid=0x3024 runnable
"GC task thread#1 (ParallelGC)" os_prio=0 tid=0x000000000299a000 nid=0x229c runnable
"GC task thread#2 (ParallelGC)" os_prio=0 tid=0x000000000299b800 nid=0x2bbc runnable
"GC task thread#3 (ParallelGC)" os_prio=0 tid=0x000000000299d000 nid=0x255c runnable
"VM Periodic Task Thread" os_prio=2 tid=0x0000000019d67800 nid=0x1c5c waiting on condition
JNI global references: 334
E:\Program Files\Java\jdk1.8.0_161\bin>


可以看到 并没有死锁的发生

或者 使用 jvisualvm 、 jmc 工具来看下都行

（jmc截图）

20191001005618588.png


并且可以看到4个线程 均是 WAITING 状态

（jmc截图）

20191001011416610.png


原因分析

20191001080629528.png


为了方便观察，我们改造下，给线程起个名

package com.artisan.test;
import java.util.stream.Stream;
public class MultiProduceConsumerDemo {
    // 对象监视器-锁
    private final Object LOCK = new Object();
    // 是否生产出数据的标识
    private boolean isProduced = false;
    // volatile 确保可见性， 假设 i 就是生产者生产的数据
    private volatile int i = 0 ;
    public  void produce(){
        synchronized (LOCK){
            System.out.println(Thread.currentThread() + " GOT LOCK  " + isProduced);
            String msg = isProduced ? "已生产货物" : "没有货物可搬运";
            if (isProduced){
                try {
                    System.out.println(Thread.currentThread() + " wait becauseof  " + msg );
                    LOCK.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }else{
                i++;
                System.out.println(Thread.currentThread() + " Produce:" + i);
                LOCK.notify();
                isProduced = true;
            }
        }
    }
    public void consume(){
        // 加锁
        synchronized (LOCK){
            System.out.println(Thread.currentThread() + " GOT LOCK " + isProduced);
            String msg = isProduced ? "已生产货物" : "没有货物可搬运";
            if (isProduced){
                System.out.println(Thread.currentThread() + " Consume:" + i);
                LOCK.notify();
                isProduced = false;
            }else{
                try {
                    System.out.println(Thread.currentThread() + " wait becauseof  " + msg);
                    LOCK.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    public static void main(String[] args) {
        MultiProduceConsumerDemo produceConsumerDemo = new MultiProduceConsumerDemo();
        Stream.of("P1","P2").forEach(n-> new Thread(n){
            @Override
            public void run() {
                while(true) produceConsumerDemo.produce();
            }
        }.start());
        Stream.of("C1","C2").forEach(n->new Thread(n){
            @Override
            public void run() {
                while(true) produceConsumerDemo.consume();
            }
        }.start());
    }
}


运行下 ，可以看到程序并没有持续运行，而是假死了…

（每次运行的结果都有可能不一样，这里我们以这次的运行结果来分析下）

2019100113383794.png


逐步分析下：

生产者的代码2019100720370841.png

消费者代码


20191007212957913.png


  1. 线程P1锁，没有货物生产，isProduce=false
  2. 线程P1,生产货物 ，紧接着 LOCK.notify(); isProduced = true; ，其实第一步的LOCK.notify() 是没有什么作用的，因为没有任何线程wait. 执行完以后释放锁。 对应日志

20191007211804997.png

  1. 紧接着，P1又抢到了锁，但是生产后没有被消费，所以直接进入LOCK.wati. 执行完以后释放锁。P1-----WAITING . 对应日志
  2. 20191007211823248.png
  3. P2同上一步P1的操作 ，P2-----WAITING 对应日志


20191007212839387.png

C1 抢到资源 ，isProduce已经生产，所以C1线程直接消费，消费完成以后要通知生产者继续生产，即唤醒消费者 （LOCK.notify();），将isProduce标志位置为false . 执行完以后，释放锁

20191007212933500.png

  1. C1-----WAITING日志如下
  2. 紧接着C1又抢到了锁，因没有生产，所以进入LOCK.wait（） ，释放锁。 对应日志

20191007213159525.png


依次类推… 直到最后C2 唤醒了C1 ,此时C1看到isProduce=false, 则C1进入了wait ,这个时候4个线程都是watiing的状态了，就出现了4个线程均是wait状态，都不执行了，出现了假死 （因为notify方法，唤醒一个线程，具体是哪个线程是不确定的。）

那如何解决呢？ 下篇博文我们一起来探讨下


文章标签：
日志服务
数据可视化
关键词：
高并发编程
编程线程
线程分析
线程notify
线程wait
相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
小小工匠
目录
相关文章
Deephub
|
17天前
|
并行计算 安全 Java
Python GIL（全局解释器锁）机制对多线程性能影响的深度分析
在Python开发中，GIL（全局解释器锁）一直备受关注。本文基于CPython解释器，探讨GIL的技术本质及其对程序性能的影响。GIL确保同一时刻只有一个线程执行代码，以保护内存管理的安全性，但也限制了多线程并行计算的效率。文章分析了GIL的必要性、局限性，并介绍了多进程、异步编程等替代方案。尽管Python 3.13计划移除GIL，但该特性至少要到2028年才会默认禁用，因此理解GIL仍至关重要。
Deephub
92 16
Python GIL（全局解释器锁）机制对多线程性能影响的深度分析
dufadayang
|
4月前
|
存储 NoSQL Redis
Redis 新版本引入多线程的利弊分析
【10月更文挑战第16天】Redis 新版本引入多线程是一个具有挑战性和机遇的改变。虽然多线程带来了一些潜在的问题和挑战，但也为 Redis 提供了进一步提升性能和扩展能力的可能性。在实际应用中，我们需要根据具体的需求和场景，综合评估多线程的利弊，谨慎地选择和使用 Redis 的新版本。同时，Redis 开发者也需要不断努力，优化和完善多线程机制，以提供更加稳定、高效和可靠的 Redis 服务。
dufadayang
107 1
阿里云开发者
|
4天前
|
缓存 监控 安全
高并发编程知识体系
本文将从线程的基础理论谈起，逐步探究线程的内存模型，线程的交互，线程工具和并发模型的发展。扫除关于并发编程的诸多模糊概念，从新构建并发编程的层次结构。
阿里云开发者
52 5
kaixin321-44007
|
4月前
|
Java 开发者
如何通过易语言多线程提升程序响应速度
如何通过易语言多线程提升程序响应速度
kaixin321-44007
276 62
最好zzz
|
2月前
|
调度 开发者
核心概念解析：进程与线程的对比分析
在操作系统和计算机编程领域，进程和线程是两个基本而核心的概念。它们是程序执行和资源管理的基础，但它们之间存在显著的差异。本文将深入探讨进程与线程的区别，并分析它们在现代软件开发中的应用和重要性。
最好zzz
82 4
最好zzz
|
3月前
|
安全 Java
线程安全的艺术：确保并发程序的正确性
在多线程环境中，确保线程安全是编程中的一个核心挑战。线程安全问题可能导致数据不一致、程序崩溃甚至安全漏洞。本文将分享如何确保线程安全，探讨不同的技术策略和最佳实践。
最好zzz
68 6
八百标兵奔北坡
|
4月前
|
Java 开发者
如何通过易语言多线程提升程序响应速度？
如何通过易语言多线程提升程序响应速度？
八百标兵奔北坡
109 1
javaedge
|
4月前
|
监控 Java API
真没想到！虚拟线程竟然这样提高程序效率！
【10月更文挑战第13天】
javaedge
65 0
代码bug生产队
|
4月前
|
并行计算 算法 搜索推荐
探索Go语言的高并发编程与性能优化
【10月更文挑战第10天】探索Go语言的高并发编程与性能优化
代码bug生产队
69 0
Dylaniou
|
4月前
|
Java Linux 应用服务中间件
【编程进阶知识】高并发场景下Bio与Nio的比较及原理示意图
本文介绍了在Linux系统上使用Tomcat部署Java应用程序时，BIO（阻塞I/O）和NIO（非阻塞I/O）在网络编程中的实现和性能差异。BIO采用传统的线程模型，每个连接请求都会创建一个新线程进行处理，导致在高并发场景下存在严重的性能瓶颈，如阻塞等待和线程创建开销大等问题。而NIO则通过事件驱动机制，利用事件注册、事件轮询器和事件通知，实现了更高效的连接管理和数据传输，避免了阻塞和多级数据复制，显著提升了系统的并发处理能力。
Dylaniou
110 0

热门文章

最新文章

  • 1
    高并发编程知识体系
  • 2
    Python GIL（全局解释器锁）机制对多线程性能影响的深度分析
  • 3
    Java线程调度揭秘：从算法到策略，让你面试稳赢！
  • 4
    Linux编程： 在业务线程中注册和处理Linux信号
  • 5
    Linux编程： 在业务线程中注册和处理Linux信号
  • 6
    多线程优化For循环：实战指南
  • 7
    面试中的难题：线程异步执行后如何共享数据？
  • 8
    Java社招面试题：一个线程运行时发生异常会怎样？
  • 9
    【JAVA】封装多线程原理
  • 10
    Java 面试必问！线程构造方法和静态块的执行线程到底是谁？
  • 1
    Java社招面试题：一个线程运行时发生异常会怎样？
    39
  • 2
    python3多线程中使用线程睡眠
    33
  • 3
    MySQL底层概述—3.InnoDB线程模型
    27
  • 4
    Java 面试必问！线程构造方法和静态块的执行线程到底是谁？
    36
  • 5
    【JAVA】封装多线程原理
    39
  • 6
    面试大神教你：如何巧妙回答线程优先级这个经典考题？
    29
  • 7
    Linux编程： 在业务线程中注册和处理Linux信号
    38
  • 8
    Unity多线程使用(线程池)
    16
  • 9
    面试中的难题：线程异步执行后如何共享数据？
    38
  • 10
    Linux编程： 在业务线程中注册和处理Linux信号
    50

    • 相关电子书

    更多
  • 多IO线程优化版
  • Redis 的高并发实战：抢购系统
  • MySQL高并发场景实战

    • 相关实验场景

    更多
  • 观察进程的并发性
  • RDS MySQL高并发访问下的系统稳定性
    • 下一篇
    PAI Model Gallery 支持云上一键部署 DeepSeek-V3、DeepSeek-R1 系列模型