锁单元测试

hsweb-web-service/hsweb-web-service-simple/src/test/java/org/hsweb/web/service/impl/cache/CacheTest.java

@@ -1,15 +0,0 @@
-package org.hsweb.web.service.impl.cache;
-
-import org.hsweb.web.service.impl.AbstractTestCase;
-import org.junit.Test;
-
-/**
- * Created by zhouhao on 16-4-26.
- */
-public class CacheTest extends AbstractTestCase {
-
-    @Test
-    public void testCache() {
-
-    }
-}

hsweb-web-service/hsweb-web-service-simple/src/test/java/org/hsweb/web/service/impl/lock/LockTest.java

@@ -0,0 +1,76 @@
+/*
+ * Copyright 2015-2016 http://hsweb.me
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.hsweb.web.service.impl.lock;
+
+import org.hsweb.concurrent.lock.LockFactory;
+import org.hsweb.web.service.impl.AbstractTestCase;
+import org.junit.Test;
+
+import javax.annotation.Resource;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReadWriteLock;
+
+public class LockTest extends AbstractTestCase {
+
+    @Resource
+    private LockFactory lockFactory;
+
+
+    @Test
+    public void testLock() throws InterruptedException {
+        Lock lock = lockFactory.createLock("test_lock");
+        new Thread(() -> {
+            try {
+                System.out.println("锁");
+                lock.lock();
+                Thread.sleep(5000);
+            } catch (InterruptedException e) {
+            }
+            System.out.println("解锁");
+            lock.unlock();
+        }).start();
+        Thread.sleep(200);
+        System.out.println("锁2");
+        lock.lock();
+        System.out.println("解锁2");
+        lock.unlock();
+        Thread.sleep(10000);
+    }
+
+    @Test
+    public void testRWLock() throws InterruptedException {
+        ReadWriteLock readWriteLock = lockFactory.createReadWriteLock("test");
+        new Thread(() -> {
+            try {
+                System.out.println("读锁");
+                readWriteLock.readLock().lock();
+                Thread.sleep(5000);
+            } catch (InterruptedException e) {
+            }
+            System.out.println("解读锁");
+            readWriteLock.readLock().unlock();
+        }).start();
+        Thread.sleep(100);
+        System.out.println("写锁");
+        readWriteLock.writeLock().tryLock(20, TimeUnit.SECONDS);
+        Thread.sleep(100);
+        System.out.println("解写锁");
+        readWriteLock.writeLock().unlock();
+        Thread.sleep(10000);
+    }
+}