Java并发：悲观锁和乐观锁机制

Author: cicadasmile

java-se-base-parent/model-multy-thread/src/main/java/com/multy/thread/block05lock01/LockThread01.java

@@ -0,0 +1,47 @@
+package com.multy.thread.block05lock01;
+
+public class LockThread01 {
+    public static void main(String[] args) {
+        CountAdd countAdd = new CountAdd() ;
+        AddThread01 addThread01 = new AddThread01(countAdd) ;
+        addThread01.start();
+        AddThread02 varThread02 = new AddThread02(countAdd) ;
+        varThread02.start();
+    }
+}
+class AddThread01 extends Thread {
+    private CountAdd countAdd  ;
+    public AddThread01 (CountAdd countAdd){
+        this.countAdd = countAdd ;
+    }
+    @Override
+    public void run() {
+        countAdd.countAdd(30);
+    }
+}
+class AddThread02 extends Thread {
+    private CountAdd countAdd  ;
+    public AddThread02 (CountAdd countAdd){
+        this.countAdd = countAdd ;
+    }
+    @Override
+    public void run() {
+        countAdd.countAdd(10);
+    }
+}
+class CountAdd {
+    private Integer count = 0 ;
+    public void countAdd (Integer num){
+        try {
+            if (num == 30){
+                count = count + 50 ;
+                Thread.sleep(3000);
+            } else {
+                count = count + num ;
+            }
+            System.out.println("num="+num+";count="+count);
+        } catch (Exception e){
+            e.printStackTrace();
+        }
+    }
+}

java-se-base-parent/model-multy-thread/src/main/java/com/multy/thread/block05lock01/LockThread02.java

@@ -0,0 +1,40 @@
+package com.multy.thread.block05lock01;
+
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+
+public class LockThread02 {
+    public static void main(String[] args) {
+        LockNum lockNum = new LockNum() ;
+        LockThread lockThread1 = new LockThread(lockNum,"TH1");
+        LockThread lockThread2 = new LockThread(lockNum,"TH2");
+        LockThread lockThread3 = new LockThread(lockNum,"TH3");
+        lockThread1.start();
+        lockThread2.start();
+        lockThread3.start();
+    }
+}
+class LockNum {
+    private Lock lock = new ReentrantLock() ;
+    public void getNum (){
+        lock.lock();
+        try {
+            for (int i = 0 ; i < 3 ; i++){
+                System.out.println("ThreadName:"+Thread.currentThread().getName()+";i="+i);
+            }
+        } finally {
+            lock.unlock();
+        }
+    }
+}
+class LockThread extends Thread {
+    private LockNum lockNum ;
+    public LockThread (LockNum lockNum,String name){
+        this.lockNum = lockNum ;
+        super.setName(name);
+    }
+    @Override
+    public void run() {
+        lockNum.getNum();
+    }
+}