课程配套课件-7.并发设计模式

实战Java高并发程序设计讲师博客

DATAGURU专业数据分析 课程详 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析 Dataguru（炼数成金）是专业数据分析，提供教育，，内容，社区，向式关于逆向式网络的详情，请看我们的培训 实战Java高并发程序设计讲师博客

DATAGURU专业数据分析什么是设计单例不变Future生产者消实战Java高并发程序设计讲师博客

DATAGURU专业数据分析在软件工程中，设计模式（designpattern）是对软件设计中普遍存在（反复出现）的各， 解决方案。这个术语是 ·伽玛（ErichGamma）等人在1990年代从建筑设计域引入到计算机科学 es《设计模式：可复用面向对象软件的基础》收录23种模实战Java高并发程序设计讲师博客

DATAGURU专业数据分析架构设计如

Stringname;intbirthYear;byte[]raw;publicbooleanequals(Objectobj)if(!obj returnother= returnname.equals()&&birthYear==}publicinthashCode(){...}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析单例对象的类必须保证只有一个实例存在。许多时候整个系统只需要拥有一个的全局对象有利于我们协调系统整体的比如：全局信息配实战Java高并发程序设计讲师博客

DATAGURU专业数据分析11publicclassSingleton23456789privateSystem.out.println("Singletonis}privatestaticSingletoninstance=newpublicstaticSingletongetInstance()return}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicpublicclassSingletonpublicstaticintprivateSystem.out.println("Singletonis}privatestaticSingletoninstance=newpublicstaticSingletongetInstance()return}}SingletonSingletonis1实战Java高并发程序设计讲师博客

DATAGURU专业数据分析01publicclassLazySingleton11

privateLazySingleton()System.out.println("LazySingletonis}privatestaticLazySingletoninstance=publicstaticsynchronizedLazySingletongetInstance()if(instance==instance=newLazySingleton();returninstance;}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析01publicclassStaticSingleton11

privateSystem.out.println("StaticSingletonis}privatestaticclassSingletonHolderprivatestaticStaticSingletoninstance=new}publicstaticStaticSingletongetInstance()return}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析一个类的内部状态创建后，在整个生命期间都不会发生变化时，就是不变不变模式不需要实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicpublicfinalclassProductprivatefinalStringprivatefinalStringprivatefinaldoublepublicProduct(Stringno,Stringname,doubleprice){this.no=no;=name;this.price=price;}publicStringgetNo()return}publicStringgetName()return}publicdoublegetPrice()return}}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析思想是异步

客户端

服务程序

服服务程客户

等待时

实战Java高并发程序设计讲师博客

DATAGURU专业数据分析

作系统启动，调用Client发出请返回Data对象，立即返回FutureData，并开启ClientThread线程装配返回数据的接Future数据，构造很快，但是是一个虚拟的数据，需要装配

FutureData-isReady:

真实数据，其构造是比较慢

立即返回，因

+装 -content:

(RealDatarealData):为返回的是Fu

+RealData(String

返 +request(StringqueryStr):调用

+getContent():实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicinterfaceDatapublicStringgetResult}

publicclassFutureDataimplementsData{protectedRealDatarealdata=null;protectedbooleanisReady=false;if(isReady)

//FutureData是RealData的包}this.realdata=realdata;isReady=true;}publicsynchronizedStringgetResult(){while(!isReady){try}catch(InterruptedExceptione)}}return}}

//RealData已经被注入，通知//会等待RealData构造完//一直等待，知道RealData被注//由RealData实实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicpublicclassRealDataimplementsData{protectedfinalStringresult;for(inti=0;i<10;i++){try}catch(InterruptedExceptione)}}result}publicStringgetResult()return}}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicpublicclassClientpublicDatarequest(finalStringqueryStr){finalFutureDatafuture=newFutureData();newThread(){publicvoidrunRealDataRealDatarealdata=new}returnfutureFutureData}}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicstaticvoidmain(String[]args)Clientclient=newDatadata=client.request("name");try}catch(InterruptedExceptione)}System.out.println}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析JDK对Future模式的支 run():

Future接口内 get(): get(): run(): get get(): run(): innerRun : call():实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicRealData(Stringpara){ publicStringcall()throwsException for(inti=0;i<10;i++)try}catch(InterruptedExceptione)} return 19实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicclassFutureMainpublicstaticvoidmain(String[]args)throwsInterruptedException,ExecutionException 20

//构造FutureTask<String>future=newFutureTask<String>(newExecutorServiceexecutor=//执行FutureTask，相当于上例中的client.request("a")发送请//在这里开启线程进行RealData的call()执System.out.println("请求完毕try}catch(InterruptedExceptione)}//相当于data.getResult()，取得call()方法的返回//如果此时call()方法System.out.println("数据="+实战Java高并发程序设计讲师博客

DATAGURU专业数据分析publicclassFutureMain2publicstaticvoidmain(String[]args)throwsInterruptedException,ExecutionExceptionExecutorServiceexecutor=//执行FutureTask，相当于上例中的client.request("a")发送请//在这里开启线程进行RealData的call()执System.out.println("请求完毕try}catch(InterruptedExceptione)}//相当于data.getResult()，取得call()方法的返回//如果此时call()方法没有执行}}实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析实战Java高并发程序设计讲师博客

DATAGURU专业数据分析

内存缓冲

消费

生产

- : getData():

创建和提数实战Java高并发程序设计讲师博客

DATAGURU专业数据分析while(isRunning)while(isRunning