开发者社区> 壮壮father> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

简介: /* * 多线程-消费者和生产者模式 * 在实现消费者生产者模式的时候必须要具备两个前提,一是,必须访问的是一个共享资源,二是必须要有线程锁,且锁的是同一个对象 * */ 1 /*资源类中定义了name(名字):用来区分消费者还是生产者 2 * 定义了flag标记:用来...
+关注继续查看

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

 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 }

 

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
基于java SSM医药住院管理系统设计和实现
主要功能设计:入院管理,登记、出院登记、查询、转房、病房管理、病房价格调整、缴费和记录、护理、住院历史、统计、药品管理、医生、用户、系统 springMVC spring mybatis jquery js css tomcat mysql
80 0
基于Java SSM springboot健身管理系统设计和实现
主要功能设计:用户登录、会员管理、教练管理、课程管理、器材管理、会员充值、物品遗失、商品管理、信息统计、修改密码 主要技术:springmvc、 springboot 、mybatis、mysql 、jQuery、layui、css、jsp shiro权限控制
62 0
基于java Springmvc+mybatis 电影院售票管理系统设计和实现以及文档
主要技术:Java springmvc mybatis jquery spring js css mysql tomcat等 主要功能描述: 客户端主要功能有: 1.用户登录注册、
67 0
基于java springboot+mybatis OA办公自动化系统设计和实现
java springbootOA办公自动化系统: 主要功能模块:系统、用户、角色、考勤、流程、公告、邮件、任务、日程、计划、文件、笔记、通讯录、讨论区等多个模块管理 使用Maven进行项目管理,基于springboot框架开发的
92 0
基于Java jsp+mysql+Spring的汽车出租平台租赁网站平台设计和实现
主要功能说明: 管理员角色包含以下功能:管理员登录, 用户管理,管理员管理, 订单管理和审核,利润统计, 交易流水管理车辆管理, 汽车品牌管理等功能。
41 0
基于java SSM的房屋租赁系统设计和实现
主要功能描述: 1.登录管理:主要有管理员登录和租客登录 2.房源列表以及添加房源功能: 3.租赁合同管理以及在租房源和已退租房源
52 0
基于java(springboot+mybatis)汽车信息管理系统设计和实现以及文档
主要实现技术:Java、springmvc、springboot、mysql、mybaits、jQuery、js、css等、使用eclipse/idea运行。 主要功能模块
58 0
基于java(springboot+mybatis)网上音乐商城设计和实现以及论文报告
主要功能模块如下: (1) 用户登录和用户注册功能: ①用户注册 : 登录系统首页用户输入相关信息进行注册 ②用户登录 :
58 0
Java Springboot+VUE前后端分离网上手机商城平台系统设计和实现以及论文报告
主要模块设计如下: 1) 用户注册和登录功能:。 2) 用户信息的管理以及角色的管理、不同用户角色具有不同的功能权限操作。 3) 商品的操作、包括商品列表信息、商品的分离、商品的详情、品牌和规格等操作。
99 0
+关注
壮壮father
从14年开始从事安卓开发。喜欢接触新鲜事物,不断的挑战自己
文章
问答
文章排行榜
最热
最新
相关电子书
更多
快速变化背景下,组织如何保持过程的稳定性
立即下载
微服务MTA的新体验
立即下载
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析
立即下载