摘要:比如需要用多線(xiàn)程或分布式集群統(tǒng)計(jì)一堆用戶(hù)的相關(guān)統(tǒng)計(jì)值,由于用戶(hù)的統(tǒng)計(jì)值是共享數(shù)據(jù),因此需要保證線(xiàn)程安全。如果類(lèi)是無(wú)狀態(tài)的,那它永遠(yuǎn)是線(xiàn)程安全的。參考探索并發(fā)編程二寫(xiě)線(xiàn)程安全的代碼
線(xiàn)程安全類(lèi) 保證類(lèi)線(xiàn)程安全的措施:
不共享線(xiàn)程間的變量;
設(shè)置屬性變量為不可變變量;
每個(gè)共享的可變變量都使用一個(gè)確定的鎖保護(hù);
保證線(xiàn)程安全的思路: 1. 通過(guò)架構(gòu)設(shè)計(jì)通過(guò)上層的架構(gòu)設(shè)計(jì)和業(yè)務(wù)分析來(lái)避免并發(fā)場(chǎng)景。比如需要用多線(xiàn)程或分布式集群統(tǒng)計(jì)一堆用戶(hù)的相關(guān)統(tǒng)計(jì)值,由于用戶(hù)的統(tǒng)計(jì)值是共享數(shù)據(jù),因此需要保證線(xiàn)程安全。從業(yè)務(wù)上分析出用戶(hù)之間的數(shù)據(jù)并不共享,因此可以設(shè)計(jì)一個(gè)規(guī)則來(lái)保證一個(gè)用戶(hù)的計(jì)算工作和數(shù)據(jù)訪(fǎng)問(wèn)只被一個(gè)線(xiàn)程或一臺(tái)機(jī)器完成,這樣從設(shè)計(jì)上避免了接下來(lái)可能的并發(fā)問(wèn)題。
2. 保證類(lèi)無(wú)狀態(tài)有狀態(tài)會(huì)限制橫向擴(kuò)展能力,也可能產(chǎn)生并發(fā)問(wèn)題。如果類(lèi)是無(wú)狀態(tài)的,那它永遠(yuǎn)是線(xiàn)程安全的。因此在設(shè)計(jì)階段盡可能用無(wú)狀態(tài)的類(lèi)來(lái)滿(mǎn)足業(yè)務(wù)需求。
3. 區(qū)別原子操作和復(fù)合操作常見(jiàn)的復(fù)合操作包括check-then-act, i++等。雖然check-then-act從表面上看很簡(jiǎn)單,但卻普遍存在與我們?nèi)粘5拈_(kāi)發(fā)中,特別是在數(shù)據(jù)庫(kù)存取這一塊。比如我們需要在數(shù)據(jù)庫(kù)里存一個(gè)客戶(hù)的統(tǒng)計(jì)值,當(dāng)統(tǒng)計(jì)值不存在時(shí)初始化,當(dāng)存在時(shí)就去更新。如果不把這組邏輯設(shè)計(jì)為原子性的就很有可能產(chǎn)生出兩條這個(gè)客戶(hù)的統(tǒng)計(jì)值。
在單機(jī)環(huán)境下處理這個(gè)問(wèn)題還算容易,通過(guò)鎖或者同步來(lái)把這組復(fù)合操作變?yōu)樵硬僮?,但在分布式環(huán)境下就不適用了。一般情況下是通過(guò)在數(shù)據(jù)庫(kù)端做文章,比如通過(guò)唯一性索引或者悲觀(guān)鎖來(lái)保障其數(shù)據(jù)一致性。當(dāng)然任何方案都是有代價(jià)的,這就需要具體情況下來(lái)權(quán)衡。
使用鎖應(yīng)注意:
每個(gè)共享變量必須由一個(gè)確定的鎖保護(hù)。
使用鎖會(huì)有性能損失
鎖不能解決在分布式環(huán)境共享變量的并發(fā)問(wèn)題。
參考:探索并發(fā)編程(二)------寫(xiě)線(xiàn)程安全的Java代碼
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.hztianpu.com/yun/65162.html
摘要:線(xiàn)程池的作用降低資源消耗。通過(guò)重復(fù)利用已創(chuàng)建的線(xiàn)程降低線(xiàn)程創(chuàng)建和銷(xiāo)毀造成的資源浪費(fèi)。而高位的部分,位表示線(xiàn)程池的狀態(tài)。當(dāng)線(xiàn)程池中的線(xiàn)程數(shù)達(dá)到后,就會(huì)把到達(dá)的任務(wù)放到中去線(xiàn)程池的最大長(zhǎng)度。默認(rèn)情況下,只有當(dāng)線(xiàn)程池中的線(xiàn)程數(shù)大于時(shí),才起作用。 線(xiàn)程池的作用 降低資源消耗。通過(guò)重復(fù)利用已創(chuàng)建的線(xiàn)程降低線(xiàn)程創(chuàng)建和銷(xiāo)毀造成的資源浪費(fèi)。 提高響應(yīng)速度。當(dāng)任務(wù)到達(dá)時(shí),不需要等到線(xiàn)程創(chuàng)建就能立即執(zhí)行...
摘要:物理計(jì)算機(jī)并發(fā)問(wèn)題在介紹內(nèi)存模型之前,先簡(jiǎn)單了解下物理計(jì)算機(jī)中的并發(fā)問(wèn)題。基于高速緩存的存儲(chǔ)交互引入一個(gè)新的問(wèn)題緩存一致性。寫(xiě)入作用于主內(nèi)存變量,把操作從工作內(nèi)存中得到的變量值放入主內(nèi)存的變量中。 物理計(jì)算機(jī)并發(fā)問(wèn)題 在介紹Java內(nèi)存模型之前,先簡(jiǎn)單了解下物理計(jì)算機(jī)中的并發(fā)問(wèn)題。由于處理器的與存儲(chǔ)設(shè)置的運(yùn)算速度有幾個(gè)數(shù)量級(jí)的差距,所以現(xiàn)代計(jì)算機(jī)加入一層讀寫(xiě)速度盡可能接近處理器的高速緩...
摘要:并發(fā)需要解決的問(wèn)題功能性問(wèn)題線(xiàn)程同步面臨兩個(gè)問(wèn)題,想象下有兩個(gè)線(xiàn)程在協(xié)作工作完成某項(xiàng)任務(wù)。鎖可用于規(guī)定一個(gè)臨界區(qū),同一時(shí)間臨界區(qū)內(nèi)僅能由一個(gè)線(xiàn)程訪(fǎng)問(wèn)。并發(fā)的數(shù)據(jù)結(jié)構(gòu)線(xiàn)程安全的容器,如等。 并發(fā)指在宏觀(guān)上的同一時(shí)間內(nèi)同時(shí)執(zhí)行多個(gè)任務(wù)。為了滿(mǎn)足這一需求,現(xiàn)代的操作系統(tǒng)都抽象出 線(xiàn)程 的概念,供上層應(yīng)用使用。 這篇博文不打算詳細(xì)展開(kāi)分析,而是對(duì)java并發(fā)中的概念和工具做一個(gè)梳理。沿著并發(fā)模...
摘要:內(nèi)存模型是圍繞著在并發(fā)過(guò)程中如何處理原子性可見(jiàn)性和有序性這個(gè)特征來(lái)建立的,我們來(lái)看下哪些操作實(shí)現(xiàn)了這個(gè)特性??梢?jiàn)性可見(jiàn)性是指當(dāng)一個(gè)線(xiàn)程修改了共享變量的值,其他線(xiàn)程能夠立即得知這個(gè)修改。 Java內(nèi)存模型是圍繞著在并發(fā)過(guò)程中如何處理原子性、可見(jiàn)性和有序性這3個(gè)特征來(lái)建立的,我們來(lái)看下哪些操作實(shí)現(xiàn)了這3個(gè)特性。 原子性(atomicity): 由Java內(nèi)存模型來(lái)直接保證原子性變量操作包括...
摘要:禁止指令重排序優(yōu)化。只有當(dāng)線(xiàn)程對(duì)變量執(zhí)行的前一個(gè)動(dòng)作是時(shí),才能對(duì)執(zhí)行動(dòng)作并且,只有當(dāng)對(duì)變量執(zhí)行的后一個(gè)動(dòng)作是時(shí),線(xiàn)程才能對(duì)變量執(zhí)行動(dòng)作。變量不需要與其他的狀態(tài)變量共同參與不變約束。在某些情況下,的同步機(jī)制性要優(yōu)于鎖。 當(dāng)一個(gè)變量定義為volatile之后,它具備兩種特性: 保證此變量對(duì)所有線(xiàn)程的可見(jiàn)性,這里的可見(jiàn)性是指當(dāng)一條線(xiàn)程修改了這個(gè)變量的值,新值對(duì)于其他線(xiàn)程來(lái)說(shuō)是可以立即得知的...
閱讀 1480·2021-09-02 09:53
閱讀 2731·2021-07-29 13:50
閱讀 1776·2019-08-30 11:07
閱讀 1628·2019-08-30 11:00
閱讀 1513·2019-08-29 14:00
閱讀 1912·2019-08-29 12:52
閱讀 2629·2019-08-29 11:11
閱讀 3486·2019-08-26 12:23