java多线程-消费者和生产者模式

/* * 多线程-消费者和生产者模式 * 在实现消费者生产者模式的时候必须要具备两个前提,一是,必须访问的是一个共享资源,二是必须要有线程锁,且锁的是同一个对象 * */

 1 /*资源类中定义了name(名字):用来区分消费者还是生产者
 2  *         定义了flag标记:用来区分有没有货物(默认生产一个就要消费一个)
 3  *         定义了count(生产的个数统计)
 4  *     set方法:用来生产商品
 5  *     out方法:用来消费商品*/
 6 class TestSource{
 7     private String name=null;
 8     private boolean flag=false;
 9     private int count=0;
10     /*先通过flag标记判断有没有商品,有商品则等待,没有则生产商品,唤醒所有程序,并将flag标记改变*/
11     public synchronized void set(String name){
12         //判断是否有产品,这里用while循环,避免在多个生产者同时生产时,会出现生产多个产品,却只消费一个
13         while(flag){
14             try {
15                 wait();
16             } catch (InterruptedException e) {
17                 e.printStackTrace();
18             }
19         }
20         //生产产品并输出
21         this.name=name+"编号"+count++;
22         System.out.println("生产"+name+"++");
23         //改变标记
24         flag=true;
25         //唤醒所有的线程
26         notifyAll();
27     }
28     public synchronized void out(){
29         while(!flag){
30             try {
31                 wait();
32             } catch (InterruptedException e) {
33                 e.printStackTrace();
34             }
35         }
36         System.out.println("消费"+name+"---");
37         flag=false;
38         notifyAll();
39     }
40 }
41 class Product implements Runnable{
42     private TestSource ts=null;
43     //初始化线程里用到的资源
44     public Product(TestSource ts){
45         this.ts=ts;
46     }
47     //重写线程里run方法
48     public void run() {
49         while(true){
50             ts.set("生产产品");
51         }
52     }
53 }
54 class Customer implements Runnable{
55     private TestSource ts=null;
56     public Customer(TestSource ts){
57         this.ts=ts;
58     }
59     public void run() {
60         while(true){
61             ts.out();
62         }
63     }
64 }
65 public class test {
66     public static void main(String[] args) {
67         //初始化唯一的资源
68         TestSource ts=new TestSource();
69         //创建生产者和消费者两个对象,并传入两者共同操作的唯一资源
70         Customer cu=new Customer(ts);
71         Product pr=new Product(ts);
72         //将对象传入线程对象
73         Thread t1=new Thread(cu);
74         Thread t2=new Thread(pr);
75         Thread t3=new Thread(cu);
76         Thread t4=new Thread(pr);
77         //开启线程
78         t1.start();
79         t2.start();
80         t3.start();
81         t4.start();
82     }
83 }

/*在java1.5版本以后,用lock和unlick代替了synchronized关键字 * 用await()代替了wait()方法 * 用signal()代替了notify() * 这里的signal可以指定唤醒莫一类的线程,而不是像notifyAll,必须全部唤醒

这里我们对上面的代码进行一定的改写*/

 1 class TestSource{
 2     private String name=null;
 3     private boolean flag=false;
 4     private int count=0;
 5     //定义lock,用来代替synchronized关键字
 6     private Lock lock=new ReentrantLock();
 7     private Condition condition_pro=lock.newCondition();
 8     private Condition condition_con=lock.newCondition();
 9     public void set(String name){
10         //对代码段进行上锁
11         lock.lock();
12         try {
13             while(flag){
14                 try {
15                     //wait();
16                     //调用生产者控制方法
17                     condition_pro.await();
18                 } catch (InterruptedException e) {
19                     e.printStackTrace();
20                 }
21             }
22             this.name=name+"编号"+count++;
23             System.out.println("生产"+name+"++");
24             flag=true;
25             //notifyAll();
26             //唤醒消费者线程
27             condition_con.signal();
28         } finally{
29             //解锁,让其他进程进入访问
30             lock.unlock();
31         }
32         
33         
34     }
35     public void out(){
36         lock.lock();
37         try{
38             while(!flag){
39                 try {
40                     //wait();
41                     condition_con.await();
42                 } catch (InterruptedException e) {
43                     e.printStackTrace();
44                 }
45             }
46             System.out.println("消费"+name+"---");
47             flag=false;
48             //notifyAll();
49             condition_pro.signal();
50         }finally{
51             lock.unlock();
52         }
53         
54     }
55 }

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏一个会写诗的程序员的博客

JVM、Java编译器和Java解释器

java解释器就是把在java虚拟机上运行的目标代码(字节码)解释成为具体平台的机器码的程序。即jdk或jre目录下bin目录中的java.exe文件,而jav...

94820
来自专栏C/C++基础

Protocol Buffers C++入门教程

protobuf(Protocol Buffers )是Google的开源项目,是Google的中立于语言、平台,可扩展的用于序列化结构化数据的解决方案。官网见...

1.4K10
来自专栏java达人

多线程设计模式解读1—Guarded Suspension(保护性暂挂模式)

大家好,今天我们给大家介绍一个多线程设计模式的一个概念,我们平时业务代码写得比较多,因此,如果刚上手写比较复杂多线程代码,很有可能会埋下一些坑,而这些坑一时之间...

10240
来自专栏木木玲

设计模式 ——— 状态模式

12820
来自专栏Java编程技术

基于rxjava的生产消费模型

最近在看springcloud的熔断机制的实现,发现底层使用的rxjava实现,就看了下rxjava的使用,发现rxjava使用可也便捷实现前面讲解的定时生产与...

10120
来自专栏Java进阶之路

由浅入深谈 Java 的类加载机制

17400
来自专栏从零开始学 Web 前端

C51单片机中data、idata、xdata、pdata的区别

data: 固定指前面0x00-0x7f的128个RAM,可以用acc直接读写的,速度最快,生成的代码也最小。

17140
来自专栏Java帮帮-微信公众号-技术文章全总结

第二十四天 多线程-多线程&线程安全【悟空教程】

进程:进程指正在运行的程序。确切的来说,当一个程序进入内存运行,即变成一个进程,进程是处于运行过程中的程序,并且具有一定独立功能。

13650
来自专栏hbbliyong

设计模式名录

本文给出了经典的23种设计模式的名录,包括他们的分类、名称、定义以及简要说明,方便大家能够快速的回忆起他们。也是前面写过的或者后面将要写的设计模式的一个目录。...

29370
来自专栏与神兽党一起成长

使用commons-pool管理FTP连接

在封装一个FTP工具类文章,已经完成一版对FTP连接的管理,设计了模板方法,为工具类上传和下载文件方法的提供获取对象和释放对象支持。

14920

扫码关注云+社区

领取腾讯云代金券