最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Java?CopyOnWriteArrayList源碼超詳細(xì)分析

 更新時間:2022年11月05日 10:22:48   作者:OlaiolaiO  
為了將讀取的性能發(fā)揮到極致,jdk中提供了CopyOnWriteArrayList類,下面這篇文章主要給大家介紹了關(guān)于java中CopyOnWriteArrayList源碼解析的相關(guān)資料,文中通過實例代碼介紹的非常詳細(xì),需要的朋友可以參考下

一、概述

CopyOnWriteArrayList是基于寫時復(fù)制技術(shù)實現(xiàn)的,適用于讀多寫少場景下的線程安全的并發(fā)容器。讀操作永遠(yuǎn)不會加鎖,讀讀、讀寫都不會沖突,只有寫寫需要等待。寫操作時,為了不影響其它線程的讀取,它會進行一次自我復(fù)制,待數(shù)據(jù)寫入完成后再替換array數(shù)組。array數(shù)組是被volatile修飾的,它被修改后可以被其他線程立刻發(fā)現(xiàn)。

public class copyOnwriteArrayList<E>
implements List<E>,RandomAccess,Cloneable,java.io.Serializable {
//加鎖: ReentrantLock
final transient ReentrantLock lock = new ReentrantLock( ) ;
// volatile:保證可見性
private transient volatile object[ ] array;
//獲取數(shù)組
final object[] getArray() ireturn array ;
}
//存入數(shù)組
final void setArray(object[ ] a) iarray = a;
}
//無參構(gòu)造方法:初始化數(shù)組,容量為日public CopyOnwriteArrayList( ) i
setArray( new object[e]);
}
//有參構(gòu)造方法:傳入集合
public CopyOnwriteArrayList(collection< ? extends E> c) {
object[] elements;
//判斷傳入的集合是否是CopyOnwriteArrayList類型if (c.getclass() == copyonwriteArrayList.class)
//獲取數(shù)組
elements = ((copyOnwriteArrayList<?>)c).getArray();else i
//將集合轉(zhuǎn)為數(shù)組
elements = c.toArray();
// c.toArray might (incorrectly) not return object[] (see 6260652)1/判斷數(shù)組是否是object[]
if (elements.getclass() i= object[].class)
//復(fù)制數(shù)組
elements = Arrays.copyof(elements,elements.length,object[ ].c1
}
setArray(elements) ;
}
setArray(elements ) ;
}

二、類圖

  • 實現(xiàn)了RandomAccess接口,代表它支持快速隨機訪問,因為它底層數(shù)據(jù)結(jié)構(gòu)是數(shù)組,支持通過下標(biāo)快速訪問;
  • 實現(xiàn)了Cloneable接口,代表它支持克隆,使用的是淺拷貝模式;
  • 實現(xiàn)了List接口,代表它是一個有序的列表容器,支持迭代遍歷等操作。

三、核心方法

1.add()

向容器中添加元素時,需要競爭鎖,同一時刻最多只有一個線程可以操作。因為是寫時復(fù)制,寫入數(shù)據(jù)時不應(yīng)該影響其他線程的讀取,因此不會直接在array數(shù)組上操作,而是拷貝一個新的數(shù)組,元素設(shè)置完成后再覆蓋舊數(shù)組。

public boolean add(E e) {
	final ReentrantLock lock = this.lock;
	lock.lock();
	try {
		Object[] elements = getArray();
		int len = elements.length;
		// 拷貝一個長度+1的數(shù)組,將元素放到末尾
		Object[] newElements = Arrays.copyOf(elements, len + 1);
        // 填充要追加的元素e
		newElements[len] = e;
        // 覆蓋舊數(shù)組
		setArray(newElements);
		return true;
	} finally {
		lock.unlock();
	}
}

2.set()

set方法用來給指定下標(biāo)設(shè)置值,同時會返回舊值。它也是一個寫入操作,因此也需要競爭到鎖才能執(zhí)行。為了不影響其它線程讀取,它會拷貝一個同樣長度的新數(shù)組,然后做數(shù)據(jù)拷貝,在新數(shù)組上完成新值的設(shè)置,最終再寫回array。

public E set(int index, E element) {
	final ReentrantLock lock = this.lock;
	lock.lock();
	try {
		Object[] elements = getArray();
		// 先獲取舊元素
		E oldValue = get(elements, index);
		if (oldValue != element) {
			int len = elements.length;
			// 拷貝一個一樣的數(shù)組,替換下標(biāo)元素,并寫入array
			Object[] newElements = Arrays.copyOf(elements, len);
			newElements[index] = element;
			setArray(newElements);
		} else {
			// 即使元素沒有變化,也要寫入array,確保volatile的寫語義
			// Not quite a no-op; ensures volatile write semantics
			setArray(elements);
		}
		return oldValue;
	} finally {
		lock.unlock();
	}
}

3.remove()

remove也是寫操作,只有競爭到鎖的線程才能執(zhí)行。它先是取出對應(yīng)下標(biāo)的舊元素,然后新建了一個原數(shù)組長度減1的新數(shù)組,完成數(shù)據(jù)拷貝后,再寫回array,整個過程依然不影響其它線程讀。

public E remove(int index) {
	final ReentrantLock lock = this.lock;
	lock.lock();
	try {
		Object[] elements = getArray();
		int len = elements.length;
		// 要移除的舊元素
		E oldValue = get(elements, index);
		int numMoved = len - index - 1;
		if (numMoved == 0)
			// 刪除的是最后一個元素,直接拷貝一個長度-1的數(shù)組寫回array即可
			setArray(Arrays.copyOf(elements, len - 1));
		else {
			// 刪除的是中間元素,拷貝一個長度-1的數(shù)組
			Object[] newElements = new Object[len - 1];
			// 拷貝前半段元素
			System.arraycopy(elements, 0, newElements, 0, index);
			// 拷貝后半段元素
			System.arraycopy(elements, index + 1, newElements, index,
					numMoved);
			// 寫回array
			setArray(newElements);
		}
		return oldValue;
	} finally {
		lock.unlock();
	}
}

4.get()

通過下標(biāo)獲取元素,直接從array數(shù)組中取。因為是寫時復(fù)制的,可能在訪問時已經(jīng)有新的元素加入,或者有元素被刪除,這是會存在延遲的,不是實時的,這是它的一個缺點。

public E get(int index) {
    // getArray()獲取的就是array
    return get(getArray(), index);
}
private E get(Object[] a, int index) {
    return (E) a[index];
}

5.size()

獲取元素的數(shù)量直接取數(shù)組的長度即可。因為CopyOnWriteArrayList的數(shù)組是不可變數(shù)組,它始終是一個被填充滿的數(shù)組對象,沒有擴容的操作,因此也沒有必要像ArrayList一樣,額外使用一個int size來記錄數(shù)量。

public int size() {
    return getArray().length;
}

四、總結(jié)

CopyOnWriteArrayList 具有以下特性:

  • 在保證并發(fā)讀取的前提下,確保了寫入時的線程安全;
  • 由于每次寫入操作時,進行了Copy復(fù)制原數(shù)組,所以無需擴容;
  • 適合讀多寫少的應(yīng)用場景。由于 add() 、 set() 、 remove() 等修改操作需要復(fù)制整 個數(shù)組,所以會有內(nèi)存開銷大的問題;
  • CopyOnWriteArrayList 由于只在寫入時加鎖,所以只能保證數(shù)據(jù)的最終一致性,不能 保證數(shù)據(jù)的實時一致性。

到此這篇關(guān)于Java CopyOnWriteArrayList源碼超詳細(xì)分析的文章就介紹到這了,更多相關(guān)Java CopyOnWriteArrayList內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • mybatis實現(xiàn)圖書管理系統(tǒng)

    mybatis實現(xiàn)圖書管理系統(tǒng)

    這篇文章主要為大家詳細(xì)介紹了mybatis實現(xiàn)圖書管理系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2020-06-06
  • Linux?Ubuntu系統(tǒng)下配置JDK環(huán)境、MySQL環(huán)境全過程

    Linux?Ubuntu系統(tǒng)下配置JDK環(huán)境、MySQL環(huán)境全過程

    眾所周知Ubuntu是一種基于Linux的操作系統(tǒng),它提供了一個穩(wěn)定、安全和易于使用的環(huán)境,下面這篇文章主要給大家介紹了關(guān)于Linux?Ubuntu系統(tǒng)下配置JDK環(huán)境、MySQL環(huán)境的相關(guān)資料,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2024-07-07
  • 使用nacos命名空間namespace用法,測試時做實例隔離

    使用nacos命名空間namespace用法,測試時做實例隔離

    Nacos命名空間用于管理多套不同環(huán)境的服務(wù)器,增加一個命名空間的概念,可以用一套Nacos注冊中心管理多套不同的環(huán)境
    2024-12-12
  • Springboot報錯java.lang.NullPointerException: null問題

    Springboot報錯java.lang.NullPointerException: null問題

    這篇文章主要介紹了Springboot報錯java.lang.NullPointerException: null問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-11-11
  • redis實現(xiàn)多進程數(shù)據(jù)同步工具代碼分享

    redis實現(xiàn)多進程數(shù)據(jù)同步工具代碼分享

    這篇文章主要介紹了使用redis實現(xiàn)多進程數(shù)據(jù)同步工具的代碼,大家參考使用吧
    2014-01-01
  • jstack配合top命令分析CPU飆高、程序死鎖問題

    jstack配合top命令分析CPU飆高、程序死鎖問題

    記得前段時間,同事說他們測試環(huán)境的服務(wù)器cpu使用率一直處于100%,本地又沒有什么接口調(diào)用,為什么會這樣?cpu使用率居高不下,自然是有某些線程一直占用著cpu資源,那又如何查看占用cpu較高的線程
    2021-09-09
  • SpringBoot中@ConfigurationProperties 配置綁定

    SpringBoot中@ConfigurationProperties 配置綁定

    本文主要介紹了SpringBoot中@ConfigurationProperties 配置綁定,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-11-11
  • Java線程中的Timer和TimerTask原理詳解

    Java線程中的Timer和TimerTask原理詳解

    這篇文章主要介紹了Java線程中的Timer和TimerTask原理詳解,Timer和TimerTask成對出現(xiàn),Timer是定時器,TimerTask是定時任務(wù),換句話說,定時任務(wù)TimerTask是給定時器Timer執(zhí)行的具體任務(wù),需要的朋友可以參考下
    2023-10-10
  • SpringBoot配置默認(rèn)HikariCP數(shù)據(jù)源

    SpringBoot配置默認(rèn)HikariCP數(shù)據(jù)源

    咱們開發(fā)項目的過程中用到很多的開源數(shù)據(jù)庫鏈接池,比如druid、c3p0、BoneCP等等,本文主要介紹了SpringBoot配置默認(rèn)HikariCP數(shù)據(jù)源,具有一定的參考價值,感興趣的可以了解一下
    2023-11-11
  • Spring AOP 自定義注解的實現(xiàn)代碼

    Spring AOP 自定義注解的實現(xiàn)代碼

    本篇文章主要介紹了Spring AOP 自定義注解的實現(xiàn)代碼,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-04-04

最新評論

上思县| 明溪县| 黔南| 庄浪县| 三穗县| 久治县| 揭东县| 吉木萨尔县| 台北县| 虎林市| 亳州市| 太白县| 寿光市| 隆安县| 汕尾市| 古丈县| 三穗县| 乐山市| 阳江市| 利津县| 衡南县| 衡东县| 石台县| 湘西| 旅游| 垫江县| 松潘县| 原阳县| 盖州市| 泽库县| 蒲城县| 弥渡县| 大英县| 昆山市| 关岭| 砚山县| 郸城县| 南昌县| 辽阳县| 彭州市| 虎林市|