了解JAVA并发工具常用设计套路
前言
在学习JAVA并发工具时,分析JUC下的源码,发现有三个利器:状态、队列、CAS。
状态
一般是state属性,如AQS源码中的状态,是整个工具的核心,一般操作的执行都要看当前状态是什么,
由于状态是多线程共享的,所以都是volatile修饰,保证线程直接内存可见。
/** *AbstractQueuedSynchronizer中的状态 */ privatevolatileintstate; /** *Statusfield,takingononlythevalues: *SIGNAL:Thesuccessorofthisnodeis(orwillsoonbe) *blocked(viapark),sothecurrentnodemust *unparkitssuccessorwhenitreleasesor *cancels.Toavoidraces,acquiremethodsmust *firstindicatetheyneedasignal, *thenretrytheatomicacquire,andthen, *onfailure,block. *CANCELLED:Thisnodeiscancelledduetotimeoutorinterrupt. *Nodesneverleavethisstate.Inparticular, *athreadwithcancellednodeneveragainblocks. *CONDITION:Thisnodeiscurrentlyonaconditionqueue. *Itwillnotbeusedasasyncqueuenode *untiltransferred,atwhichtimethestatus *willbesetto0.(Useofthisvalueherehas *nothingtodowiththeotherusesofthe *field,butsimplifiesmechanics.) *PROPAGATE:AreleaseSharedshouldbepropagatedtoother *nodes.Thisisset(forheadnodeonly)in *doReleaseSharedtoensurepropagation *continues,evenifotheroperationshave *sinceintervened. *0:Noneoftheabove * *Thevaluesarearrangednumericallytosimplifyuse. *Non-negativevaluesmeanthatanodedoesn'tneedto *signal.So,mostcodedoesn'tneedtocheckforparticular *values,justforsign. * *Thefieldisinitializedto0fornormalsyncnodes,and *CONDITIONforconditionnodes.ItismodifiedusingCAS *(orwhenpossible,unconditionalvolatilewrites). */ volatileintwaitStatus;
队列
队列一般由链表实现(单向链表,双向链表),在线程获取不到想要的资源或者状态时,将线程封装成特定节点,扔到等待队列中,等待时机成熟,再从队列中取出,是悲观锁思想。
如AQS中的Node节点,代码太长就不贴了。
CAS
CAS操作是乐观锁思想,是轻量级的并发处理。一般用于对上述状态的修改,而且能保证有且只有一个线程能修改这个状态。
一般由Unsafe类中的compareAndSwap之类的方法实现。使用CAS,往往伴随自旋,如果修改状态失败,则不断地重试,直到修改状态成功。
以上就是java并发编程中的套路,抓住这个思路,想必能在学习中有所帮助。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。