AtomicStampedReferenceDemo

Author: ZHENFENG13

src/chapter4/AtomicStampedReferenceDemo.java

@@ -0,0 +1,61 @@
+package chapter4;
+
+import java.util.concurrent.atomic.AtomicStampedReference;
+
+/**
+ * Created by 13 on 2017/5/6.
+ */
+public class AtomicStampedReferenceDemo {
+    static AtomicStampedReference<Integer> money = new AtomicStampedReference<Integer>(19, 0);
+
+    public static void main(String args[]) {
+
+        for (int i = 0; i < 100; i++) {
+            final int timestap = money.getStamp();
+            new Thread() {
+                public void run() {
+                    while (true) {
+                        Integer m = money.getReference();
+                        if (m < 20) {
+                            if (money.compareAndSet(m, m + 20, timestap, timestap + 1)) {
+                                System.out.println("余额小于20元,充值成功,余额:" + money.getReference() + "元");
+                                break;
+                            }
+                        } else {
+                            System.out.println("余额大于20,无需充值");
+                            break;
+                        }
+                    }
+                }
+            }.start();
+        }
+
+        new Thread() {
+            public void run() {
+                for (int i = 0; i < 100; i++) {
+
+                    while (true) {
+                        int timestap = money.getStamp();
+                        Integer m = money.getReference();
+                        if (m > 10) {
+                            System.out.println("金额大于10元");
+                            if (money.compareAndSet(m, m - 10, timestap, timestap + 1)) {
+                                System.out.println("成功消费10元,余额:" + money.getReference() + "元");
+                                break;
+                            }
+                        } else {
+                            System.out.println("没有足够的金额");
+                            break;
+                        }
+                    }
+                    try {
+                        Thread.sleep(100);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+        }.start();
+
+    }
+}