最近2018中文字幕在日韩欧美国产成人片_国产日韩精品一区二区在线_在线观看成年美女黄网色视频_国产精品一区三区五区_国产精彩刺激乱对白_看黄色黄大色黄片免费_人人超碰自拍cao_国产高清av在线_亚洲精品电影av_日韩美女尤物视频网站

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Java中如何解決ABA問題

這篇文章主要為大家展示了“Java中如何解決ABA問題”,內(nèi)容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領(lǐng)大家一起研究并學習一下“Java中如何解決ABA問題”這篇文章吧。

主要從事網(wǎng)頁設(shè)計、PC網(wǎng)站建設(shè)(電腦版網(wǎng)站建設(shè))、wap網(wǎng)站建設(shè)(手機版網(wǎng)站建設(shè))、響應(yīng)式網(wǎng)站建設(shè)、程序開發(fā)、微網(wǎng)站、小程序設(shè)計等,憑借多年來在互聯(lián)網(wǎng)的打拼,我們在互聯(lián)網(wǎng)網(wǎng)站建設(shè)行業(yè)積累了豐富的網(wǎng)站設(shè)計制作、成都網(wǎng)站制作、網(wǎng)絡(luò)營銷經(jīng)驗,集策劃、開發(fā)、設(shè)計、營銷、管理等多方位專業(yè)化運作于一體,具備承接不同規(guī)模與類型的建設(shè)項目的能力。

代碼如下:

public class Node {
	public final String item;
	public Node next;
	public Node(String item){
		this.item = item;
	}
}
public class ConcurrentStack {
	AtomicReference top = new AtomicReference();
	public void push(String item){
		Node newTop = new Node(item);
		Node oldTop;
		do{
			oldTop = top.get();
			newTop.next = oldTop;
		}
		while(!top.compareAndSet(oldTop, newTop));
	}
	public String pop(){
		Node newTop;
		Node oldTop;
		do{
			oldTop = top.get();
			if(oldTop == null){
				return null;
			}
			newTop = oldTop.next;
		}
		while(!top.compareAndSet(oldTop, newTop));
		return oldTop.item;
	}
}

這個例子并不會引發(fā)ABA問題,至于為什么不會,后面再講解,下面先講一下ABA問題

什么是ABA?

引用原書的話:如果在算法中的節(jié)點可以被循環(huán)使用,那么在使用“比較并交換”指令就可能出現(xiàn)這種問題,在CAS操作中將判斷“V的值是否仍然為A?”,并且如果是的話就繼續(xù)執(zhí)行更新操作,在某些算法中,如果V的值首先由A變?yōu)锽,再由B變?yōu)锳,那么CAS將會操作成功

ABA的例子

有時候,ABA造成的后果很嚴重,下面將并發(fā)棧的例子修改一下,看看ABA會造成什么問題:

public class Node {
	public final String item;
	public Node next;
	public Node(String item){
		this.item = item;
	}
}
public class ConcurrentStack {
	AtomicReference top = new AtomicReference();
	public void push(Node node){
		Node oldTop;
		do{
			oldTop = top.get();
			node.next = oldTop;
		}
		while(!top.compareAndSet(oldTop, node));
	}
	public Node pop(int time){
		Node newTop;
		Node oldTop;
		do{
			oldTop = top.get();
			if(oldTop == null){
				return null;
			}
			newTop = oldTop.next;
			TimeUnit.SECONDS.sleep(time);
		}
		while(!top.compareAndSet(oldTop, newTop));
		return oldTop;
	}
}

注意這里的變化,Node基本沒有變化

重點關(guān)注ConcurrentStack的變化

1、push方法:原來是使用內(nèi)容構(gòu)造Node,現(xiàn)在直接傳入Node,這樣就符合了“在算法中的節(jié)點可以被循環(huán)使用”這個要求

2、pop方法的sleep,這是模擬線程的執(zhí)行情況,以便觀察結(jié)果

我們先往stack中壓入兩個Node:

ConcurrentStack stack = new ConcurrentStack(); 
stack.push(new Node("A")); 
stack.push(new Node("B"));

然后創(chuàng)建兩個線程來執(zhí)行出入棧的操作

線程A先執(zhí)行出棧:讓NodeA出棧

stack.pop(3);

因為某些原因,線程A執(zhí)行出棧比較久,用了3s

線程B執(zhí)行出棧之后再入棧:先然NodeA和NodeB出棧,然后讓NodeD,NodeC,NodeA入棧(NodeA在棧頂)

Node A = stack.pop(0); 
stack.pop(0); 
stack.push(new Node("D")); 
stack.push(new Node("C")); 
stack.push(A);

注意:線程B實現(xiàn)了節(jié)點的循環(huán)利用,它先將棧里面的內(nèi)容全部出棧,然后入棧,最后棧頂?shù)膬?nèi)容是之前出棧的Node

線程B執(zhí)行完這些動作之后,線程A才執(zhí)行CAS,此時CAS是可以執(zhí)行成功的

按照原來的想法,線程A和B執(zhí)行之后,stack的內(nèi)容應(yīng)該是:C和D,C在棧頂,但這里的執(zhí)行結(jié)果卻是Stack中什么都沒有,這就是ABA問題

如何避免ABA問題

Java中提供了AtomicStampedReference和AtomicMarkableReference來解決ABA問題

AtomicStampedReference可以原子更新兩個值:引用和版本號,通過版本號來區(qū)別節(jié)點的循環(huán)使用,下面看AtomicStampedReference的例子:

public class ConcurrentStack {
	AtomicStampedReference top = new AtomicStampedReference(null,0);
	public void push(Node node){
		Node oldTop;
		int v;
		do{
			v=top.getStamp();
			oldTop = top.getReference();
			node.next = oldTop;
		}
		while(!top.compareAndSet(oldTop, node,v,v+1));
		//   }while(!top.compareAndSet(oldTop, node,top.getStamp(),top.getStamp()+1));
	}
	public Node pop(int time){
		Node newTop;
		Node oldTop;
		int v;
		do{
			v=top.getStamp();
			oldTop = top.getReference();
			if(oldTop == null){
				return null;
			}
			newTop = oldTop.next;
			try {
				TimeUnit.SECONDS.sleep(time);
			}
			catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		while(!top.compareAndSet(oldTop, newTop,v,v+1));
		//   }while(!top.compareAndSet(oldTop, newTop,top.getStamp(),top.getStamp())); 
		return oldTop;
	}
	public void get(){
		Node node = top.getReference();
		while(node!=null){
			System.out.println(node.getItem());
			node = node.getNode();
		}
	}
}

注意:不能使用注釋中的方式,否則就和單純使用原子變量沒有區(qū)別了

AtomicMarkableReference可以原子更新一個布爾類型的標記位和引用類型,看下面的例子:

AtomicMarkableReference top = new AtomicMarkableReference(null,true);
public void push(Node node){
	Node oldTop;
	Boolean v;
	do{
		v=top.isMarked();
		oldTop = top.getReference();
		node.next = oldTop;
	}
	while(!top.compareAndSet(oldTop, node,v,!v));
}

以上是“Java中如何解決ABA問題”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學習更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!


標題名稱:Java中如何解決ABA問題
本文地址:http://fisionsoft.com.cn/article/gsgidi.html