yesleecoder
diff --git a/Collapse file
‎src/main/java/cn/byhieg/threadtutorial/concurrent/atom/AtomFactory.java‎
Copy file name to clipboard
+36Lines changed: 36 additions & 0 deletions b/Collapse file
‎src/main/java/cn/byhieg/threadtutorial/concurrent/atom/AtomFactory.java‎
Copy file name to clipboard
+36Lines changed: 36 additions & 0 deletions
diff --git a/Collapse file
‎src/main/java/cn/byhieg/threadtutorial/concurrent/atom/MyObject.java‎
Copy file name to clipboard
+12Lines changed: 12 additions & 0 deletions b/Collapse file
‎src/main/java/cn/byhieg/threadtutorial/concurrent/atom/MyObject.java‎
Copy file name to clipboard
+12Lines changed: 12 additions & 0 deletions
diff --git a/Collapse file
‎src/test/java/cn/byhieg/threadtutorialtest/concurrenttest/atomtest/AtomFactoryTest.java‎
Copy file name to clipboard
+69Lines changed: 69 additions & 0 deletions b/Collapse file
‎src/test/java/cn/byhieg/threadtutorialtest/concurrenttest/atomtest/AtomFactoryTest.java‎
Copy file name to clipboard
+69Lines changed: 69 additions & 0 deletions
@@ -0,0 +1,36 @@
+package cn.byhieg.threadtutorial.concurrent.atom;
+
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicIntegerArray;
+import java.util.concurrent.atomic.AtomicLong;
+import java.util.concurrent.atomic.AtomicReference;
+
+/**
+ * Created by shiqifeng on 2017/5/5.
+ * Mail byhieg@gmail.com
+ */
+public class AtomFactory {
+
+    private static final AtomFactory atomFactory = new AtomFactory();
+
+    private AtomFactory(){
+
+    }
+
+    public static AtomFactory getInstance(){
+        return atomFactory;
+    }
+
+    public AtomicInteger createAtomInt(int a){
+        return new AtomicInteger(a);
+    }
+
+    public AtomicIntegerArray createAtomArray(int[] a) {
+        return new AtomicIntegerArray(a);
+    }
+
+    public AtomicReference<MyObject> createAtomReference(MyObject object){
+        AtomicReference<MyObject> objectAtomicReference = new AtomicReference<>();
+        return objectAtomicReference;
+    }
+}
@@ -0,0 +1,12 @@
+package cn.byhieg.threadtutorial.concurrent.atom;
+
+/**
+ * Created by shiqifeng on 2017/5/5.
+ * Mail byhieg@gmail.com
+ */
+public class MyObject {
+
+    public String name = "byhieg";
+    public int age = 24;
+    public volatile int id = 1;
+}
@@ -0,0 +1,69 @@
+package cn.byhieg.threadtutorialtest.concurrenttest.atomtest;
+
+import cn.byhieg.threadtutorial.concurrent.atom.AtomFactory;
+
+import cn.byhieg.threadtutorial.concurrent.atom.MyObject;
+import junit.framework.TestCase;
+
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicIntegerArray;
+import java.util.concurrent.atomic.AtomicReference;
+
+/**
+ * Created by shiqifeng on 2017/5/5.
+ * Mail byhieg@gmail.com
+ */
+public class AtomFactoryTest extends TestCase {
+    AtomicInteger integer;
+    AtomicIntegerArray array;
+    AtomicReference<MyObject> reference;
+
+    public void setUp() throws Exception {
+        super.setUp();
+        integer = AtomFactory.getInstance().createAtomInt(1);
+    }
+
+    public void testAtomInt() throws Exception {
+        new Thread(()->{
+            for (int i = 0; i < 10; i++) {
+                integer.getAndIncrement();
+                System.out.println(getName() + " " + integer.get());
+            }
+        }).start();
+
+        new Thread(()->{
+            for (int i = 0; i < 10; i++) {
+                integer.getAndIncrement();
+                System.out.println(getName() + " " + integer.get());
+            }
+        }).start();
+
+        Thread.sleep(1000);
+    }
+
+    public void testAtomArray() throws Exception {
+        int [] value = new int[]{1,2,3,4};
+        array = AtomFactory.getInstance().createAtomArray(value);
+        array.getAndSet(1,10);
+        System.out.println(array.get(1));
+        System.out.println(value[1]);
+    }
+
+    public void testAtomRef()throws Exception {
+        MyObject object = new MyObject();
+        reference = AtomFactory.getInstance().createAtomReference(object);
+        reference.set(object);
+        MyObject newObject = new MyObject();
+        newObject.name = "xiaoli";
+        reference.compareAndSet(object, newObject);
+        System.out.println(reference.get().name);
+
+    }
+
+
+    public void tearDown() throws Exception {
+
+    }
+
+
+}