zoukankan      html  css  js  c++  java
  • 【Java】LockAdapter(Lock 简单模板封装)

    ReentrantLock 简单模板封装

    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.function.Supplier;
    
    /**
     * A simple adapter mode of {@link java.util.concurrent.locks.Lock}
     * 
     * @since 1.8
     */
    public final class LockAdapter {
    
        private static Lock _lock_ = null;
        
        public LockAdapter() {
            this(new ReentrantLock());
        }
        
        public LockAdapter (Lock lock) {
            _lock_ = lock;
        }
        
        // --------------------------------------------------------------------------------------------
        
        public void lock(Runnable runnable) {
            if (runnable == null) { return; }
            _lock_.lock();
            try {
                runnable.run();
            } finally {
                _lock_.unlock();
            }
        }
        
        public <R> R lock(Supplier<R> supplier) {
            if (supplier == null) { return null; }
            _lock_.lock();
            try {
                return supplier.get();
            } finally {
                _lock_.unlock();
            }
        }
    
        
    }
    

    ReentrantReadWriteLock 简单模板封装

    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import java.util.function.Supplier;
    
    /**
     * A simple adapter mode of {@link java.util.concurrent.locks.ReadWriteLock}
     * 
     * @since 1.8
     */
    public final class ReadWriteLockAdapter {
    
        private static Lock _rl_ = null;
        private static Lock _wl_ = null;
        
        public ReadWriteLockAdapter() {
            this(new ReentrantReadWriteLock());
        }
        
        public ReadWriteLockAdapter(ReadWriteLock rwl) {
            _rl_ = rwl.readLock();
            _wl_ = rwl.writeLock();
        }
        
        // --------------------------------------------------------------------------------------------
        
        public void readLock(Runnable runnable) {
            if (runnable == null) { return; }
            _rl_.lock();
            try {
                runnable.run();
            } finally {
                _rl_.unlock();
            }
        }
        
        public <R> R readLock(Supplier<R> supplier) {
            if (supplier == null) { return null; }
            _rl_.lock();
            try {
                return supplier.get();
            } finally {
                _rl_.unlock();
            }
        }   
        
        
        // --------------------------------------------------------------------------------------------
        
        public void writeLock(Runnable runnable) {
            if (runnable == null) { return; }
            _wl_.lock();
            try {
                runnable.run();
            } finally {
                _wl_.unlock();
            }
        }
        
        public <R> R writeLock(Supplier<R> supplier) {
            if (supplier == null) { return null; }
            _wl_.lock();
            try {
                return supplier.get();
            } finally {
                _wl_.unlock();
            }
        }
        
        
    }
    
  • 相关阅读:
    序列化 Serialization
    http soap关系
    sql 查询
    返回最后插入到标识列的值(scope_identity.ident_current.@@identity)
    匿名方法
    九、volatile与Java内存模型
    八、Java内存模型JMM
    十、CAS
    CUSTOM ROUTE CONSTRAINTS
    获取本地数据库
  • 原文地址:https://www.cnblogs.com/zhuzhongxing/p/14147112.html
Copyright © 2011-2022 走看看