JAVA并发编程.doc
上传人:sy****28 上传时间:2024-09-13 格式:DOC 页数:7 大小:49KB 金币:14 举报 版权申诉
预览加载中,请您耐心等待几秒...

JAVA并发编程.doc

JAVA并发编程.doc

预览

在线预览结束,喜欢就下载吧,查找使用更方便

14 金币

下载此文档

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

Java并发编程:Volatile不能保证数据同步在本篇博文中,将给出一个实例去验证volatile修饰的变量并不能保证其数据同步。在本篇博文中,将给出一个实例去验证volatile修饰的变量并不能保证其数据同步。Java内存模型规定了所有变量都存储在主内存中,每条线程都有自己的工作内存,线程的工作内存保存了被该线程使用到变量的主内存副本拷贝,线程对变量的所有操作(读取,赋值等)都必须在工作内存中进行,而不能直接读写主内存中的变量。不同线程也不能直接访问对方工作内存中的变量,线程间变量值的传递均需要通过主内存来完成,线程,主内存,工作内存三者的交互关系如图所示。当一个变量定义成volatile之后,保证了此变量对所有线程的可见性,也就是说当一条线程修改了这个变量的值,新的值对于其它线程来说是可以立即得知的.此时,该变量的读写操作直接在主内存中完成.Volatile变量具有synchronized的可见性特性,但是不具备原子特性。Volatilevariablessharethevisibilityfeaturesofsynchronized,butnoneoftheatomicityfeatures.虽然增量操作(x++)看上去类似一个单独操作,实际上它是一个由读取-修改-写入操作序列组成的组合操作,必须以原子方式执行,而volatile不能提供必须的原子特性。Whiletheincrementoperation(x++)maylooklikeasingleoperation,itisreallyacompoundread-modify-writesequenceofoperationsthatmustexecuteatomically--andvolatiledoesnotprovidethenecessaryatomicity.在多线程并发的环境下,各个线程的读/写操作可能有重叠现象,在这个时候,volatile并不能保证数据同步.下面将给出一个实例:实例==>500个线程一起运行,每个线程对1到100求和1000次操作,然后将一个volatile共享变量值加1.当500个线程都完成操作之后,期望的值是500,因为每个线程执行完毕之后都会对这个volatile变量加1.一直循环执行这个程序,直到出现volatile变量的值小于500为止,也就是出现数据不同步。publicclassNonSafeThreadimplementsRunnable{/**共享资源,每个线程执行完之后加1*/privatevolatileintvolatileCount=0;publicvoidrun(){/**每个线程调用sum100()方法,1000次*/for(inti=1;i<=1000;i++){sum100();}/**计算完毕之后,volatileCount加1*/increase();}privatevoidincrease(){volatileCount++;}/***对1到100求和*/privateintsum100(){intresult=0;for(inti=1;i<=100;i++){result+=i;}returnresult;}/***@returnthevolatileCount*/publicintgetVolatileCount(){returnvolatileCount;}}/***@authorEric**@version1.0*/publicclassNonSafeThreadTest{publicstaticvoidmain(String[]args){/**记录循环次数*/intloopCount=0;/**以main函数主线程创建一个是线程组*/ThreadGroupthreadGroup=Thread.currentThread().getThreadGroup();for(;;){loopCount++;/**启动500个线程,初始化的线程会添加到当前线程组中*/NonSafeThreadnonSafeThread=newNonSafeThread();startThreads(nonSafeThread);/**如果线程组中除了主线程之外,还有其它线程,则休眠5毫秒,然后再判断线程组中剩余的线程数,直到只剩下主线程一个为止。*/while(!isOnlyMainThreadLeft(threadGroup)){sleep(5);}/**500个线程运行完毕,那么此时的volatile变量volatileC