update

AQS/AQS.iml

@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>

AQS/src/com/wangyz/aqs/CustomLock.java

@@ -0,0 +1,75 @@
+package com.wangyz.aqs;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.AbstractQueuedSynchronizer;
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+
+public class CustomLock implements Lock {
+
+    private Sync sync = new Sync();
+
+    @Override
+    public void lock() {
+        System.out.println(Thread.currentThread().getName() + " ready get lock");
+        sync.acquire(1);
+        System.out.println(Thread.currentThread().getName() + " already got lock");
+    }
+
+    @Override
+    public void lockInterruptibly() throws InterruptedException {
+        sync.acquireInterruptibly(1);
+    }
+
+    @Override
+    public boolean tryLock() {
+        return sync.tryAcquire(1);
+    }
+
+    @Override
+    public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
+        return sync.tryAcquireNanos(1, unit.toNanos(time));
+    }
+
+    @Override
+    public void unlock() {
+        System.out.println(Thread.currentThread().getName() + " ready release lock");
+        sync.release(1);
+        System.out.println(Thread.currentThread().getName() + " already released lock");
+    }
+
+    @Override
+    public Condition newCondition() {
+        return sync.newCondition();
+    }
+
+    private static class Sync extends AbstractQueuedSynchronizer {
+        @Override
+        protected boolean tryAcquire(int arg) {
+            if (compareAndSetState(0, 1)) {
+                setExclusiveOwnerThread(Thread.currentThread());
+                return true;
+            }
+            return false;
+        }
+
+        @Override
+        protected boolean tryRelease(int arg) {
+            if (getState() == 0) {
+                throw new IllegalMonitorStateException();
+            }
+            setExclusiveOwnerThread(null);
+            setState(0);
+            return true;
+        }
+
+        @Override
+        protected boolean isHeldExclusively() {
+            return getState() == 1;
+        }
+
+        Condition newCondition() {
+            return new ConditionObject();
+        }
+    }
+}

AQS/src/com/wangyz/aqs/CustomReentrantLock.java

@@ -0,0 +1,83 @@
+package com.wangyz.aqs;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.AbstractQueuedSynchronizer;
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+
+public class CustomReentrantLock implements Lock {
+
+    private Sync sync = new Sync();
+
+    @Override
+    public void lock() {
+        System.out.println(Thread.currentThread().getName() + " ready get lock");
+        sync.acquire(1);
+        System.out.println(Thread.currentThread().getName() + " already got lock");
+    }
+
+    @Override
+    public void lockInterruptibly() throws InterruptedException {
+        sync.acquireInterruptibly(1);
+    }
+
+    @Override
+    public boolean tryLock() {
+        return sync.tryAcquire(1);
+    }
+
+    @Override
+    public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
+        return sync.tryAcquireNanos(1, unit.toNanos(time));
+    }
+
+    @Override
+    public void unlock() {
+        System.out.println(Thread.currentThread().getName() + " ready release lock");
+        sync.release(1);
+        System.out.println(Thread.currentThread().getName() + " already released lock");
+    }
+
+    @Override
+    public Condition newCondition() {
+        return sync.newCondition();
+    }
+
+    private static class Sync extends AbstractQueuedSynchronizer {
+        @Override
+        protected boolean tryAcquire(int arg) {
+            if (compareAndSetState(0, 1)) {
+                setExclusiveOwnerThread(Thread.currentThread());
+                return true;
+            } else if (getExclusiveOwnerThread() == Thread.currentThread()) {
+                setState(getState() + 1);
+                return true;
+            }
+            return false;
+        }
+
+        @Override
+        protected boolean tryRelease(int arg) {
+            if (getExclusiveOwnerThread() != Thread.currentThread()) {
+                throw new IllegalMonitorStateException();
+            }
+            if (getState() == 0) {
+                throw new IllegalMonitorStateException();
+            }
+            setState(getState() - 1);
+            if (getState() == 0) {
+                setExclusiveOwnerThread(null);
+            }
+            return true;
+        }
+
+        @Override
+        protected boolean isHeldExclusively() {
+            return getState() > 0;
+        }
+
+        Condition newCondition() {
+            return new ConditionObject();
+        }
+    }
+}

README.md

@@ -90,4 +90,8 @@ IntelliJ IDEA插件开发
 
 ### 23、 CustomView
 
-自定义View,包括FlowLayout,ViewGroup
+自定义View,包括FlowLayout,ViewGroup
+
+### 24、AQS
+
+对AQS的简单理解及自定义锁的实现