电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

如何使用JCTools實現Java并發程序

瀏覽:123日期:2022-08-15 13:38:36
概述

在本文中,我們將介紹JCTools(Java并發工具)庫。

簡單地說,這提供了許多適用于多線程環境的實用數據結構。

非阻塞算法

傳統上,在可變共享狀態下工作的多線程代碼使用鎖來確保數據一致性和發布(一個線程所做的更改對另一個線程可見)。

這種方法有許多缺點:

線程在試圖獲取鎖時可能會被阻塞,在另一個線程的操作完成之前不會取得任何進展—這有效地防止了并行性 鎖爭用越重,JVM處理調度線程、管理爭用和等待線程隊列的時間就越多,實際工作就越少 如果涉及多個鎖,并且它們以錯誤的順序獲取/釋放,則可能出現死鎖 優先級反轉的危險是可能的——高優先級線程被鎖定,試圖獲得由低優先級線程持有的鎖 大多數情況下,使用粗粒度鎖會嚴重損害并行性—細粒度鎖需要更仔細的設計,增加鎖開銷,并且更容易出錯

另一種方法是使用非阻塞算法,即任何線程的故障或掛起都不會導致另一個線程的故障或掛起的算法。

如果所涉及的線程中至少有一個能夠在任意時間段內取得進展,即在處理過程中不會出現死鎖,則非阻塞算法是無鎖的。

此外,如果保證每個線程的進程,這些算法是無等待的。

下面是一個非阻塞堆棧示例,它定義了基本狀態:

public class ConcurrentStack<E> { AtomicReference<Node<E>> top = new AtomicReference<Node<E>>(); private static class Node <E> { public E item; public Node<E> next; // standard constructor }}

還有一些API方法:

public void push(E item){ Node<E> newHead = new Node<E>(item); Node<E> oldHead; do { oldHead = top.get(); newHead.next = oldHead; } while(!top.compareAndSet(oldHead, newHead));}public E pop() { Node<E> oldHead; Node<E> newHead; do { oldHead = top.get(); if (oldHead == null) { return null; } newHead = oldHead.next; } while (!top.compareAndSet(oldHead, newHead)); return oldHead.item;}

我們可以看到,該算法使用細粒度比較和交換(CAS)指令,并且是無鎖的(即使多個線程調用top.compareAndSet()同時,它們中的一個保證會成功)但不能無等待,因為不能保證CAS最終會對任何特定線程成功。

依賴

首先,讓我們將JCTools依賴項添加到pom.xml文件:

<dependency> <groupId>org.jctools</groupId> <artifactId>jctools-core</artifactId> <version>2.1.2</version></dependency>

請注意,Maven Central上提供了最新的可用版本。

JCTools隊列

該庫提供了許多隊列以在多線程環境中使用,即一個或多個線程以線程安全的無鎖方式寫入隊列,一個或多個線程以線程安全的無鎖方式從隊列中讀取。

所有隊列實現的通用接口是org.jctools.queues.MessagePassingQueue。

隊列類型所有隊列都可以根據其生產者/消費者策略進行分類:

單個生產者,單個消費者?此類類使用前綴Spsc命名,例如SpscArrayQueue 單個生產者,多個消費者?使用Spmc前綴,例如SpmcArrayQueue 多個生產者,單個消費者-使用Mpsc前綴,例如MpscArrayQueue 多個生產者、多個消費者—使用Mpmc前綴,例如MpmcArrayQueue

需要注意的是,在內部沒有策略檢查,也就是說,如果使用不正確,隊列可能會無聲地發生故障。

例如,下面的測試從兩個線程填充單個生產者隊列并通過,即使不能保證使用者看到來自不同生產者的數據:

SpscArrayQueue<Integer> queue = new SpscArrayQueue<>(2);Thread producer1 = new Thread(() -> queue.offer(1));producer1.start();producer1.join();Thread producer2 = new Thread(() -> queue.offer(2));producer2.start();producer2.join();Set<Integer> fromQueue = new HashSet<>();Thread consumer = new Thread(() -> queue.drain(fromQueue::add));consumer.start();consumer.join();assertThat(fromQueue).containsOnly(1, 2);隊列實現

總結以上分類,以下是JCTools隊列列表:

SpscArrayQueue?單個生產者,單個消費者,在內部使用一個數組,限制容量 SpscLinkedQueue?單個生產者,單個消費者,內部使用鏈表,未綁定容量 SpscChunkedArrayQueue?單生產商、單消費者,從初始容量開始,一直增長到最大容量 SpscGrowableArrayQueue?單生產者、單消費者,從初始容量開始,一直增長到最大容量。這與SpscChunkedArrayQueue是相同的契約,唯一的區別是內部塊管理。建議使用SpscChunkedArrayQueue,因為它有一個簡化的實現 SpscUnboundedArrayQueue?單個生產者,單個消費者,在內部使用數組,未綁定容量 SpmcArrayQueue?單個生產者、多個使用者,在內部使用一個陣列,限制容量 MpscArrayQueue—多個生產者、單個消費者在內部使用一個陣列,限制容量 MpscLinkedQueue?多個生產者,單個消費者,在內部使用鏈表,未綁定容量 MpmcArrayQueue—多個生產者、多個消費者在內部使用一個陣列,限制容量 原子隊列

前面提到的所有隊列都使用sun.misc.Unsafe. 然而,隨著java9和JEP-260的出現,這個API在默認情況下變得不可訪問。

因此,有其他隊列使用java.util.concurrent.atomic.AtomicLongFieldUpdater(公共API,性能較差)而不是sun.misc.Unsafe.

它們是從上面的隊列生成的,它們的名稱中間插入了單詞Atomic,例如SpscChunkedAtomicArrayQueue或MpmcAtomicArrayQueue。

如果可能,建議使用“常規”隊列,并且僅在sun.misc.Unsafe像Hot Java9+和JRockit一樣被禁止/無效。

容量

所有JCTools隊列也可能具有最大容量或未綁定。當隊列已滿且受容量限制時,它將停止接受新元素。

在以下示例中,我們:

填滿隊列 確保在此之后停止接受新元素 從中排出,并確保之后可以添加更多元素

請注意,為了可讀性,刪除了幾個代碼語句。

SpscChunkedArrayQueue<Integer> queue = new SpscChunkedArrayQueue<>(8, 16);CountDownLatch startConsuming = new CountDownLatch(1);CountDownLatch awakeProducer = new CountDownLatch(1);Thread producer = new Thread(() -> { IntStream.range(0, queue.capacity()).forEach(i -> { assertThat(queue.offer(i)).isTrue(); }); assertThat(queue.offer(queue.capacity())).isFalse(); startConsuming.countDown(); awakeProducer.await(); assertThat(queue.offer(queue.capacity())).isTrue();});producer.start();startConsuming.await();Set<Integer> fromQueue = new HashSet<>();queue.drain(fromQueue::add);awakeProducer.countDown();producer.join();queue.drain(fromQueue::add);assertThat(fromQueue).containsAll( IntStream.range(0, 17).boxed().collect(toSet()));其他數據結構工具

JCTools還提供了一些非隊列數據結構。

它們都列在下面:

NonBlockingHashMap?一個無鎖的ConcurrentHashMap替代方案,具有更好的伸縮性和通常更低的突變成本。它是實現sun.misc.Unsafe,因此,不建議在Java9+或JRockit環境中使用此類 NonBlockingHashMapLong?與NonBlockingHashMap類似,但使用基本長鍵 NonBlockingHashSet?一個簡單的包裝器,圍繞著像JDK的java.util.Collections.newSetFromMap()一樣的NonBlockingHashMap NonBlockingIdentityHashMap?與NonBlockingHashMap類似,但按標識比較鍵。 NonBlockingSetInt?一個多線程位向量集,實現為一個原始long數組。在無聲自動裝箱的情況下工作無效 性能測試

讓我們使用JMH來比較JDK的ArrayBlockingQueue和JCTools隊列的性能。JMH是Sun/Oracle JVM gurus提供的一個開源微基準框架,它保護我們不受編譯器/JVM優化算法的不確定性的影響。

請注意,為了提高可讀性,下面的代碼段遺漏了幾個語句。

public class MpmcBenchmark { @Param({PARAM_UNSAFE, PARAM_AFU, PARAM_JDK}) public volatile String implementation; public volatile Queue<Long> queue; @Benchmark @Group(GROUP_NAME) @GroupThreads(PRODUCER_THREADS_NUMBER) public void write(Control control) { // noinspection StatementWithEmptyBody while (!control.stopMeasurement && !queue.offer(1L)) { // intentionally left blank } } @Benchmark @Group(GROUP_NAME) @GroupThreads(CONSUMER_THREADS_NUMBER) public void read(Control control) { // noinspection StatementWithEmptyBody while (!control.stopMeasurement && queue.poll() == null) { // intentionally left blank } }}

結果:

MpmcBenchmark.MyGroup:MyGroup·p0.95 MpmcArrayQueue sample 1052.000 ns/opMpmcBenchmark.MyGroup:MyGroup·p0.95 MpmcAtomicArrayQueue sample 1106.000 ns/opMpmcBenchmark.MyGroup:MyGroup·p0.95 ArrayBlockingQueue sample 2364.000 ns/op

我們可以看到,MpmcArrayQueue的性能略好于MpmcAtomicArrayQueue,而ArrayBlockingQueue的速度慢了兩倍。

使用JCTools的缺點

使用JCTools有一個重要的缺點——不可能強制正確使用庫類。例如,考慮在我們的大型成熟項目中開始使用MpscArrayQueue的情況(注意,必須有一個使用者)。

不幸的是,由于項目很大,有可能有人出現編程或配置錯誤,現在從多個線程讀取隊列。這個系統看起來像以前一樣工作,但現在有可能消費者錯過了一些信息。這是一個真正的問題,可能會有很大的影響,是很難調試。

理想情況下,應該可以運行具有特定系統屬性的系統,該屬性強制JCTools確保線程訪問策略。例如,本地/測試/暫存環境(而不是生產環境)可能已啟用它。遺憾的是,JCTools沒有提供這樣的屬性。

另一個需要考慮的問題是,盡管我們確保JCTools比JDK的對應工具快得多,但這并不意味著我們的應用程序獲得了與我們開始使用自定義隊列實現時相同的速度。大多數應用程序不會在線程之間交換很多對象,而且大多是I/O綁定的。

結論

現在,我們對JCTools提供的實用程序類有了基本的了解,并了解了它們在重載下與JDK的對應類相比的性能。

總之,只有當我們在線程之間交換大量對象時,才有必要使用該庫,即使這樣,也有必要非常小心地保留線程訪問策略。

以上示例的完整源代碼地址:https://github.com/eugenp/tutorials/tree/master/libraries-5

JCTools git地址:https://github.com/JCTools/JCTools

以上就是如何使用JCTools實現Java并發程序的詳細內容,更多關于使用JCTools實現Java并發程序的資料請關注好吧啦網其它相關文章!

標簽: Java
相關文章:
主站蜘蛛池模板: 中山市派格家具有限公司【官网】 | 永嘉县奥阳陶瓷阀门有限公司 | 旋转/数显粘度计-运动粘度测定仪-上海平轩科学仪器 | 政府回应:200块在义乌小巷能买到爱情吗?——揭秘打工族省钱约会的生存智慧 | 压接机|高精度压接机|手动压接机|昆明可耐特科技有限公司[官网] 胶泥瓷砖胶,轻质粉刷石膏,嵌缝石膏厂家,腻子粉批发,永康家德兴,永康市家德兴建材厂 | 馋嘴餐饮网_餐饮加盟店火爆好项目_餐饮连锁品牌加盟指南创业平台 | 老城街小面官网_正宗重庆小面加盟技术培训_特色面馆加盟|牛肉拉面|招商加盟代理费用多少钱 | 高空重型升降平台_高空液压举升平台_高空作业平台_移动式升降机-河南华鹰机械设备有限公司 | 爆炸冲击传感器-无线遥测传感器-航天星百科| 防火门-专业生产甲级不锈钢钢质防火门厂家资质齐全-广东恒磊安防设备有限公司 | 定制奶茶纸杯_定制豆浆杯_广东纸杯厂_[绿保佳]一家专业生产纸杯碗的厂家 | 储气罐,真空罐,缓冲罐,隔膜气压罐厂家批发价格,空压机储气罐规格型号-上海申容压力容器集团有限公司 | 定硫仪,量热仪,工业分析仪,马弗炉,煤炭化验设备厂家,煤质化验仪器,焦炭化验设备鹤壁大德煤质工业分析仪,氟氯测定仪 | 混合气体腐蚀试验箱_盐雾/硫化氢/气体腐蚀试验箱厂家-北京中科博达 | 工业洗衣机_工业洗涤设备_上海力净工业洗衣机厂家-洗涤设备首页 bkzzy在职研究生网 - 在职研究生招生信息咨询平台 | 农业仪器网 - 中国自动化农业仪器信息交流平台 | 酒店厨房设计_中央厨房设计_北京商用厨房设计公司-奇能商厨 | 儿童乐园|游乐场|淘气堡招商加盟|室内儿童游乐园配套设备|生产厂家|开心哈乐儿童乐园 | 高温链条油|高温润滑脂|轴承润滑脂|机器人保养用油|干膜润滑剂-东莞卓越化学 | 德国GMN轴承,GMN角接触球轴承,GMN单向轴承,GMN油封,GMN非接触式密封 | 运动木地板_体育木地板_篮球馆木地板_舞台木地板-实木运动地板厂家 | 深圳善跑体育产业集团有限公司_塑胶跑道_人造草坪_运动木地板 | 快干水泥|桥梁伸缩缝止水胶|伸缩缝装置生产厂家-广东广航交通科技有限公司 | 切铝机-数控切割机-型材切割机-铝型材切割机-【昆山邓氏精密机械有限公司】 | 常州翔天实验仪器厂-恒温振荡器-台式恒温振荡器-微量血液离心机 恒温恒湿箱(药品/保健品/食品/半导体/细菌)-兰贝石(北京)科技有限公司 | 冷凝锅炉_燃气锅炉_工业燃气锅炉改造厂家-北京科诺锅炉 | 珠海冷却塔降噪维修_冷却塔改造报价_凉水塔风机维修厂家- 广东康明节能空调有限公司 | 武汉印刷厂-不干胶标签印刷厂-武汉不干胶印刷-武汉标签印刷厂-武汉标签制作 - 善进特种标签印刷厂 | 纯化水设备-纯水设备-超纯水设备-[大鹏水处理]纯水设备一站式服务商-东莞市大鹏水处理科技有限公司 | 天津散热器_天津暖气片_天津安尼威尔散热器制造有限公司 | 板式换热器_板式换热器价格_管式换热器厂家-青岛康景辉 | 武汉高低温试验机-现货恒温恒湿试验箱-高低温湿热交变箱价格-湖北高天试验设备 | 北京森语科技有限公司-模型制作专家-展览展示-沙盘模型设计制作-多媒体模型软硬件开发-三维地理信息交互沙盘 | 精密钢管,冷拔精密无缝钢管,精密钢管厂,精密钢管制造厂家,精密钢管生产厂家,山东精密钢管厂家 | 注塑机-压铸机-塑料注塑机-卧式注塑机-高速注塑机-单缸注塑机厂家-广东联升精密智能装备科技有限公司 | 板式换网器_柱式换网器_自动换网器-郑州海科熔体泵有限公司 | 预制直埋蒸汽保温管-直埋管道-聚氨酯发泡保温管厂家 - 唐山市吉祥保温工贸有限公司 | 上海小程序开发-小程序制作-上海小程序定制开发公司-微信商城小程序-上海咏熠 | 课件导航网_ppt课件_课件模板_课件下载_最新课件资源分享发布平台 | 卫生型双针压力表-高温防腐差压表-安徽康泰电气有限公司 | 干粉砂浆设备_干混砂浆生产线_腻子粉加工设备_石膏抹灰砂浆生产成套设备厂家_干粉混合设备_砂子烘干机--郑州铭将机械设备有限公司 |