前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Java实现生产者和消费者模式

Java实现生产者和消费者模式

作者头像
技术交流
发布2022-11-18 17:10:22
4650
发布2022-11-18 17:10:22
举报
文章被收录于专栏:@学习笔记@学习笔记

生产者和消费者模式:一个线程负责生产,一个线程负责消费,最终要让生产者和消费者必须均衡。 wait()和notify()方法建立在synchronized线程同步的基础之上。 ** 对象.wait()方法会让正在该对象上活动的当前线程进入等待状态,并且释放之前占有的该对象的锁。 对象.notify()方法只会通知,不会释放之前占有的该对象的锁。 ** 一个经典例子: 使用生产者和消费者模式实现,交替输出: 假设只有两个线程,输出以下结果: t1–>1 t2–>2 t1–>3 t2–>4 t1–>5 t2–>6 …

代码语言:javascript
复制
	要求:必须交替输出,并且t1线程负责输出奇数。t2线程负责输出偶数。
	两个线程共享一个数字
代码语言:javascript
复制
package com.java.exam;
/*
使用多线程进行交替输出奇数偶数。t1输出奇数,t2输出偶数。
 */

public class ProductTest {
    public static void main(String[] args) {
        Num num = new Num() ;
        Thread t1 = new Thread(new Odd(num));
        Thread t2 = new Thread(new Even(num));
        t1.setName("t1");
        t2.setName("t2");
        t1.start();
        t2.start();
    }
}
class Num {
    int i = 1;
}
class Odd implements Runnable {
    private Num num;

    public Odd(Num num) {
        this.num = num;
    }

    @Override
    public void run() {
        while(true) {
            synchronized (num) {

                if(num.i % 2 == 0) {
                    try {
                        Thread.sleep(1000);//睡眠一秒能更好看到执行结国
                        //当前线程进入等待状态,并且释放Odd之前占有的num的锁
                        num.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                 //程序可以执行到这说明num是奇数
                System.out.println(Thread.currentThread().getName()+"---->" + num.i++);
                num.notifyAll();
            }
        }
    }
}
class Even implements Runnable {
    private Num num;

    public Even(Num num) {
        this.num = num;
    }

    @Override
    public void run() {
        while(true) {
            synchronized (num) {
                if(num.i % 2 == 1) {
                    try {
                        Thread.sleep(1000);
                        //当前线程进入等待状态,并且释放Even之前占有的num的锁
                        num.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                程序可以执行到这说明num是偶数
                System.out.println(Thread.currentThread().getName()+"---->" + num.i++);

                num.notifyAll();
            }
        }
    }
}
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2021-08-04,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档