AtomicRefrenceDemo

Author: ZHENFENG13

src/chapter4/AtomicRefrenceDemo.java

@@ -0,0 +1,60 @@
+package chapter4;
+
+import java.util.concurrent.atomic.AtomicReference;
+
+/**
+ * Created by 13 on 2017/5/6.
+ */
+public class AtomicRefrenceDemo {
+
+    //运行中可能不会出现书中提到的情况
+    public static void main(String args[]) {
+        final AtomicReference<Integer> money = new AtomicReference<Integer>();
+        money.set(19);
+
+        for (int i = 0; i < 100; i++) {
+            new Thread() {
+                public void run() {
+                    while (true) {
+                        Integer m = money.get();
+                        if (m < 20) {
+                            if (money.compareAndSet(m, m + 20)) {
+                                System.out.println("余额小于20元,充值成功,余额:" + money.get() + "元");
+                                break;
+                            }
+                        } else {
+                            System.out.println("余额大于20,无需充值");
+                            break;
+                        }
+                    }
+                }
+            }.start();
+        }
+
+        new Thread() {
+            public void run() {
+                for (int i = 0; i < 100; i++) {
+
+                    while (true) {
+                        Integer m = money.get();
+                        if (m > 10) {
+                            System.out.println("金额大于10元");
+                            if (money.compareAndSet(m, m - 10)) {
+                                System.out.println("成功消费10元,余额:" + money.get() + "元");
+                                break;
+                            }
+                        } else {
+                            System.out.println("没有足够的金额");
+                            break;
+                        }
+                    }
+                    try {
+                        Thread.sleep(100);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+        }.start();
+    }
+}