Java-architect
diff --git a/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/SyncDemo01.java‎
Lines changed: 0 additions & 31 deletions b/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/SyncDemo01.java‎
Lines changed: 0 additions & 31 deletions
diff --git a/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/SyncDemo02.java‎
Lines changed: 0 additions & 33 deletions b/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/SyncDemo02.java‎
Lines changed: 0 additions & 33 deletions
diff --git a/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/SynchronizedDemo01.java‎
Lines changed: 33 additions & 0 deletions b/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/SynchronizedDemo01.java‎
Lines changed: 33 additions & 0 deletions
diff --git a/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/UnSynchronizedDemo.java‎
Lines changed: 39 additions & 0 deletions b/‎codes/concurrent/src/main/java/io/github/dunwu/javase/concurrent/sync/UnSynchronizedDemo.java‎
Lines changed: 39 additions & 0 deletions
@@ -0,0 +1,33 @@
+package io.github.dunwu.javase.concurrent.sync;
+
+
+@SuppressWarnings("all")
+public class SynchronizedDemo01 {
+
+    public static void main(String[] args) {
+        new Thread(new UnSynchronizedDemo.MyThread("线程A")).start();
+        new Thread(new UnSynchronizedDemo.MyThread("线程B")).start();
+        new Thread(new UnSynchronizedDemo.MyThread("线程C")).start();
+    }
+
+    static class MyThread implements Runnable {
+
+        private int ticket = 5; // 假设一共有5张票
+
+        @Override
+        public void run() {
+            for (int i = 0; i < 100; i++) {
+                synchronized (this) { // 要对当前对象进行同步
+                    if (ticket > 0) { // 还有票
+                        try {
+                            Thread.sleep(300); // 加入延迟
+                        } catch (InterruptedException e) {
+                            e.printStackTrace();
+                        }
+                        System.out.println("卖票：ticket = " + ticket--);
+                    }
+                }
+            }
+        }
+    }
+};
@@ -0,0 +1,39 @@
+package io.github.dunwu.javase.concurrent.sync;
+
+/**
+ * 未同步的多线程示例，因为存在竞态条件，所以线程不安全。
+ * @author Zhang Peng
+ * @date 2018/5/21
+ */
+@SuppressWarnings("all")
+public class UnSynchronizedDemo {
+
+    public static void main(String[] args) {
+        new Thread(new MyThread("线程A")).start();
+        new Thread(new MyThread("线程B")).start();
+        new Thread(new MyThread("线程C")).start();
+    }
+
+    static class MyThread extends Thread {
+
+        private int ticket = 5; // 假设一共有5张票
+
+        public MyThread(String name) {
+            super(name);
+        }
+
+        @Override
+        public void run() {
+            for (int i = 0; i < 100; i++) {
+                if (ticket > 0) { // 还有票
+                    try {
+                        Thread.sleep(300); // 加入延迟
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                    System.out.println(Thread.currentThread().getName() + " 卖票：ticket = " + ticket--);
+                }
+            }
+        }
+    }
+}