2025年【趣说JAVA】什么是生产者消费者模式-用恶趣味的方式来解释

科技前沿 • 2025-03-28 15:53 • 阅读 60

大家好，我是讯享网，很高兴认识大家。

故事背景：

从前有一个产奥力给怪物叫扎克，因为自己喜欢产奥力给，所以没人喜欢它，它很自卑，直到有天遇到了一个叫老八的吞翔人，两人惺惺相惜，上演了一出生产者和消费者模式的gay情故事。扎克拉完到厕所，厕所满了老八吃，老八吃完，扎克拉，扎克拉完…

前置知识：

咱们要用到wait和notifyAll这两个方法，这两个方法不是线程的方法，是每个对象都有的方法，是在Object里面的方法，注意：wait和notify的操作是建立在同步的基础之上的，如果多线程同时操作一个对象会出现线程安全的问题， wait方法：对象.wait()是让当前操作这个对象的线程进入等待状态，也就是释放锁。 notifyAll:唤醒所有操作当前对象的线程(等待状态的)，不会释放🔒

讯享网

代码：

生产者扎克：

讯享网//扎克线程,生产者，喜欢拉翔 class Zark extends Thread{ 
    private List wc; //厕所集合 public Zark(List wc){ 
    this.wc = wc; } @Override public void run() { 
    while (true){ 
    synchronized (wc){ 
    //锁厕所，因为待会扎克和老八要操作同一个厕所 if (wc.size()>0){ 
    //厕所里面有奥力给 try { 
    wc.wait(); //有奥力给，扎克就不拉 } catch (InterruptedException e) { 
    e.printStackTrace(); } } for (int i = 0; i < 3; i++) { 
    String shit = "奥力给【"+ UUID.randomUUID().toString().substring(0,4)+"】"; //uuid来区分是哪一坨奥力给，相当于id System.out.println(Thread.currentThread().getName()+"在厕所里面拉了["+shit+"]"); wc.add(shit); } wc.notifyAll();//拉完了就唤醒在等待的线程，说:可以吃奥力给了 } } } }

消费者老八

//老八线程，消费者，喜欢吃翔 class OldEight extends Thread{ 
    private List wc; public OldEight(List wc){ 
    this.wc = wc; } @Override public void run() { 
    while (true){ 
    synchronized (wc){ 
    if (wc.size()==0){ 
    //没奥力给了，老八就等扎克拉 try { 
    wc.wait(); } catch (InterruptedException e) { 
    e.printStackTrace(); } } for (int i = 0; i < wc.size(); i++) { 
    Object remove = wc.remove(0); System.out.println(Thread.currentThread().getName()+":把厕所里的["+ remove+"]吃了"); } wc.notifyAll(); } } } }

主方法测试

讯享网public static void main(String[] args) { 
    List<String> wc = new ArrayList<>(); Thread zark = new Zark(wc); Thread laoba = new OldEight(wc); zark.setName("扎克"); laoba.setName("葫芦岛老八"); zark.start(); laoba.start(); }

看看运行结果：

在这里插入图片描述

2025年【趣说JAVA】什么是生产者消费者模式-用恶趣味的方式来解释

故事背景：

前置知识：

代码：

看看运行结果：

相关推荐