java怎樣制作線程安全的計(jì)數(shù)器？

java怎樣制作線程安全的計(jì)數(shù)器？相信大部分人都不太了解，今天小編為了讓大家更加了解java怎樣制作線程安全的計(jì)數(shù)器，給大家總結(jié)了以下內(nèi)容，一起往下看吧。

• 線程安全的計(jì)數(shù)器實(shí)現(xiàn)原理簡(jiǎn)介:
  在java中volatile關(guān)鍵字可以保證共享數(shù)據(jù)的可見(jiàn)性，它會(huì)把更新后的數(shù)據(jù)從工作內(nèi)存刷新進(jìn)共享內(nèi)存，并使其他線程中工作內(nèi)存中的數(shù)據(jù)失效，進(jìn)而從主存中讀入最新值來(lái)保證共享數(shù)據(jù)的可見(jiàn)性，實(shí)現(xiàn)線程安全的計(jì)數(shù)器通過(guò)循環(huán)CAS操作來(lái)實(shí)現(xiàn)。就是先獲取一個(gè)舊期望值值，再比較獲取的值與主存中的值是否一致，一致的話就更新，不一致的話接著循環(huán)，直到成功為止.

• 具體代碼實(shí)現(xiàn)

public class Count{
	private int count = 0;
	private AtomicInteger atomicI = new AtomicInteger(0);
	public static void main(String[] args){
		final Count cas = new Count();
		List<Thread> list = new ArrayList<Thread>();
		long start = System.currentTimeMillis();
		for(int j=0;j<100;j++){
			Thread t = new Thread(new Runnable(){
				@Override
				public void run(){
					for(int i=0;i<1000;i++){
						cas.count();
						cas.safeCount();
					}
				}
			});
			list.add(t);
		}
		//啟動(dòng)線程
		for(Thread t:list){
		t.start();
		}
		//等待所有線程執(zhí)行完畢
		for(Thread t:list){
			try{
				t.join();
				}catch(Exception e){
				e.printStackTrace();
				}
		}
		System.out.println("線程不安全:"+cas.count);
		System.out.println("線程安全:"+cas.atomicI.get());
		System.out.println("耗時(shí):"+(System.currentTimeMillis() - start));
	}
	/**線程不安全的計(jì)數(shù)器*/
	public void count(){
		count++;
	}
	/**線程安全的計(jì)數(shù)器，循環(huán)CAS*/
	public void safeCount(){
		for(;;){
			int temp = atomicI.get();
			if(atomicI.compareAndSet(temp,++temp))
			  break;
		}
	}
}

執(zhí)行結(jié)果:

以上就是java如何實(shí)現(xiàn)線程安全的計(jì)數(shù)器的內(nèi)容，有需要的朋友可以參考一下，望對(duì)大家有所幫助，更多請(qǐng)關(guān)注億速云其它相關(guān)文章！