synchronized计数器

CodeCoderCoding · CodeCoderCoding · commit 1b51812f3158 · 2022-04-27T21:25:29.000+08:00
diff --git a/src/EConcurrency/Secure/Synchronized/Counter.java b/src/EConcurrency/Secure/Synchronized/Counter.java
@@ -0,0 +1,18 @@
+package EConcurrency.Secure.Synchronized;
+
+/**
+ * @author CodeCoderCoding
+ */
+public class Counter {
+
+    private int count;
+
+    public synchronized void incr(){
+        count ++;
+    }
+
+    public synchronized int getCount() {
+        return count;
+    }
+
+}
diff --git a/src/EConcurrency/Secure/Synchronized/UseCounter.java b/src/EConcurrency/Secure/Synchronized/UseCounter.java
@@ -0,0 +1,33 @@
+package EConcurrency.Secure.Synchronized;
+
+/**
+ * @author CodeCoderCoding
+ */
+public class UseCounter extends Thread{
+    Counter counter;
+
+    public UseCounter(Counter counter) {
+        this.counter = counter;
+    }
+
+    @Override
+    public void run() {
+        for(int i= 0; i<1000; i++) {
+            counter.incr();
+        }
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        int num = 1000;
+        Counter counter = new Counter();
+        Thread[] threads = new Thread[num];
+        for (int i = 0; i < num; i++) {
+            threads[i] = new UseCounter(counter);
+            threads[i].start();
+        }
+        for (int i = 0; i < num; i++) {
+            threads[i].join();
+        }
+        System.out.println(counter.getCount());
+    }
+}
