Add synchronized demo

XGerry · XGerry · commit 4ff74614658e · 2018-12-21T18:05:44.000+08:00
diff --git a/src/Synchronized/HasSelfPrivateNum.java b/src/Synchronized/HasSelfPrivateNum.java
@@ -0,0 +1,27 @@
+package Synchronized;
+
+/**
+ * @author:Gerry
+ * @description:
+ * @date: Created in 2018/12/21
+ */
+public class HasSelfPrivateNum {
+    private int num = 0;
+
+    synchronized public void addI(String username) {
+        try {
+            if (username.equals("a")) {
+                num = 100;
+                System.out.println("a set over!");
+                //如果去掉hread.sleep(2000)，那么运行结果就会显示为同步的效果
+                Thread.sleep(2000);
+            } else {
+                num = 200;
+                System.out.println("b set over!");
+            }
+            System.out.println(username + " num=" + num);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/src/Synchronized/Run.java b/src/Synchronized/Run.java
@@ -0,0 +1,17 @@
+package Synchronized;
+
+/**
+ * @author:Gerry
+ * @description:
+ * @date: Created in 2018/12/21
+ */
+public class Run {
+    public static void main(String[] args) {
+        HasSelfPrivateNum numRef1 = new HasSelfPrivateNum();
+        HasSelfPrivateNum numRef2 = new HasSelfPrivateNum();
+        ThreadA threadA = new ThreadA(numRef1);
+        threadA.start();
+        ThreadB threadB = new ThreadB(numRef2);
+        threadB.start();
+    }
+}
diff --git a/src/Synchronized/ThreadA.java b/src/Synchronized/ThreadA.java
@@ -0,0 +1,21 @@
+package Synchronized;
+
+/**
+ * @author:Gerry
+ * @description:
+ * @date: Created in 2018/12/21
+ */
+public class ThreadA extends Thread {
+    private HasSelfPrivateNum numRef;
+
+    public ThreadA(HasSelfPrivateNum numRef) {
+        super();
+        this.numRef = numRef;
+    }
+
+    @Override
+    public void run() {
+        super.run();
+        numRef.addI("a");
+    }
+}
diff --git a/src/Synchronized/ThreadB.java b/src/Synchronized/ThreadB.java
@@ -0,0 +1,21 @@
+package Synchronized;
+
+/**
+ * @author:Gerry
+ * @description:
+ * @date: Created in 2018/12/21
+ */
+public class ThreadB extends Thread {
+    private HasSelfPrivateNum numRef;
+
+    public ThreadB(HasSelfPrivateNum numRef) {
+        super();
+        this.numRef = numRef;
+    }
+
+    @Override
+    public void run() {
+        super.run();
+        numRef.addI("b");
+    }
+}
diff --git a/src/ThreadDemo/InterruptDemo.java b/src/ThreadDemo/InterruptDemo.java
@@ -0,0 +1,34 @@
+package ThreadDemo;
+
+/**
+ * @author:Gerry
+ * @description:使用interrupt()方法终止线程
+ * @date: Created in 2018/12/21
+ */
+public class InterruptDemo extends Thread {
+    @Override
+    public void run() {
+        super.run();
+        for (int i = 0; i < 500000; i++) {
+            if (this.interrupted()) {
+                System.out.println("已经是停止状态了!我要退出了!");
+               // break;  //使用break无法停止线程
+                return;  //使用return停止线程
+            }
+            System.out.println("i=" + (i + 1));
+        }
+        System.out.println("看到这句话说明线程并未终止------");
+    }
+
+    public static void main(String[] args) {
+        try {
+            InterruptDemo thread = new InterruptDemo();
+            thread.start();
+            Thread.sleep(2000);
+            thread.interrupt();
+        } catch (InterruptedException ex) {
+            System.out.println("main catch");
+            ex.printStackTrace();
+        }
+    }
+}
diff --git a/src/ThreadDemo/MyThread1.java b/src/ThreadDemo/MyThread1.java
@@ -0,0 +1,33 @@
+package ThreadDemo;
+
+/**
+ * @author:Gerry
+ * @description:多个线程之间不共享变量线程安全的情况
+ * @date: Created in 2018/12/21
+ */
+public class MyThread1 extends Thread {
+    private int count = 5;
+
+    public MyThread1(String name) {
+        super();
+        this.setName(name);
+    }
+
+    @Override
+    public void run() {
+        super.run();
+        while (count > 0) {
+            count--;
+            System.out.println("由 " + MyThread1.currentThread().getName() + " 计算，count=" + count);
+        }
+    }
+
+    public static void main(String[] args) {
+        MyThread1 thread1 = new MyThread1("A");
+        MyThread1 thread2 = new MyThread1("B");
+        MyThread1 thread3 = new MyThread1("C");
+        thread1.start();
+        thread2.start();
+        thread3.start();
+    }
+}
diff --git a/src/ThreadDemo/SharedVariableThread.java b/src/ThreadDemo/SharedVariableThread.java
@@ -0,0 +1,33 @@
+package ThreadDemo;
+
+/**
+ * @author:Gerry
+ * @description:多个线程之间共享变量线程不安全的情况
+ * @date: Created in 2018/12/21
+ */
+public class SharedVariableThread extends Thread {
+    private int count = 5;
+
+    @Override
+    public void run() {
+        super.run();
+        while (count > 0) {
+            count--;
+            System.out.println("由 " + SharedVariableThread.currentThread().getName() + " 计算，count=" + count);
+        }
+    }
+
+    public static void main(String[] args) {
+        SharedVariableThread thread = new SharedVariableThread();
+        Thread a = new Thread(thread, "A");
+        Thread b = new Thread(thread, "B");
+        Thread c = new Thread(thread, "C");
+        Thread d = new Thread(thread, "D");
+        Thread e = new Thread(thread, "E");
+        a.start();
+        b.start();
+        c.start();
+        d.start();
+        e.start();
+    }
+}
