原子类也并不完全安全:方法与方法之间的调用有可能顺序错误

Author: frankdevhub

Concurrency Programming Core/com-frankdevhub-multi-thread/src/com/frankdevhub/foo/chp2/Chp_2_3_6_AtomicIntegerService.java

@@ -0,0 +1,31 @@
+package com.frankdevhub.foo.chp2;
+
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * @ClassName: Chp_2_3_6_AtomicIntegerService
+ * @author: [email protected]
+ * @date: 2019年11月16日 下午5:57:02
+ * @description: 原子类也并不完全安全:方法与方法之间的调用有可能顺序错误
+ * @Copyright: 2019 www.frankdevhub.site Inc. All rights reserved.
+ */
+
+public class Chp_2_3_6_AtomicIntegerService {
+	// 此处如果修改为
+	// static AtomicLong aiRef = new AtomicLong(0L);
+	// 可以保持原子性和方法调用均保持有序输出
+
+	public static AtomicLong aiRef = new AtomicLong(0L);
+
+	public long getValue() {
+		return aiRef.get();
+	}
+
+	synchronized public void addNum() {
+		System.out.println(
+				"threadName=" + Thread.currentThread().getName() 
+				+ " add 100 return value=" + aiRef.addAndGet(100));
+
+		aiRef.addAndGet(1);
+	}
+}

Concurrency Programming Core/com-frankdevhub-multi-thread/src/com/frankdevhub/foo/chp2/Chp_2_3_6_AtomicIntegerUnSafeTest.java

@@ -12,29 +12,10 @@
 
 public class Chp_2_3_6_AtomicIntegerUnSafeTest {
 
-	protected class MyService {
-		// 此处如果修改为
-		// static AtomicLong aiRef = new AtomicLong(0L);
-		// 可以保持原子性和方法调用均保持有序输出
-		
-		private AtomicLong aiRef = new AtomicLong(0L);
-
-		public long getValue() {
-			return aiRef.get();
-		}
-		
-		synchronized public void addNum() {
-			System.out.println("threadName="+Thread.currentThread().getName()
-					+ " add 100 return value=" + aiRef.addAndGet(100));
-			
-			aiRef.addAndGet(1);
-		}
-	}
-
 	protected class MyThread extends Thread {
-		private MyService service;
+		private Chp_2_3_6_AtomicIntegerService service;
 
-		public MyThread(MyService service) {
+		public MyThread(Chp_2_3_6_AtomicIntegerService service) {
 			super();
 			this.service = service;
 		}
@@ -44,24 +25,25 @@ public void run() {
 			service.addNum();
 		}
 	}
-	
+
 	// threadName=Thread-2 add 100 return value=200
 	// threadName=Thread-4 add 100 return value=500
 	// threadName=Thread-3 add 100 return value=300
 	// threadName=Thread-0 add 100 return value=100
 	// threadName=Thread-1 add 100 return value=400
 	// last value print in main=505
-	
+
 	public static void main(String[] args) {
 		try {
 			Chp_2_3_6_AtomicIntegerUnSafeTest test = new Chp_2_3_6_AtomicIntegerUnSafeTest();
-			MyService service = test.new MyService();
+			Chp_2_3_6_AtomicIntegerService service = new Chp_2_3_6_AtomicIntegerService();
 			Thread[] threads = new Thread[5];
-			
-			for(int i=0;i<threads.length;i++){
-			    threads[i] = test.new MyThread(service);
+
+			for (int i = 0; i < threads.length; i++) {
+				threads[i] = test.new MyThread(service);
+				threads[i].setName("thread-[" + (i + 1) + "]");
 			}
-			
+
 			for (int j = 0; j < threads.length; j++) {
 				threads[j].start();
 			}
@@ -72,7 +54,7 @@ public static void main(String[] args) {
 		} catch (InterruptedException e) {
 			e.printStackTrace();
 		}
-		
+
 	}
 
 }