zoukankan      html  css  js  c++  java
  • 了解什么是AQS

    1.什么是AQS

    AQS,全称AbstractQueuedSynchronizer,是队列同步器,本身是一个抽象类。

    下面看看CountDownLatch是如何实现AQS的

    public class CountDownLatch {
        //继承了AQS
        private static final class Sync extends AbstractQueuedSynchronizer {
            private static final long serialVersionUID = 4982264981922014374L;
            //设置state值
            Sync(int count) {
                setState(count);
            }
            int getCount() {
                return getState();
            }
            //重写两个方法
            protected int tryAcquireShared(int acquires) {
                return (getState() == 0) ? 1 : -1;
            }
            protected boolean tryReleaseShared(int releases) {
                // Decrement count; signal when transition to zero
                for (;;) {
                    int c = getState();
                    if (c == 0)
                        return false;
                    int nextc = c-1;
                    if (compareAndSetState(c, nextc))
                        return nextc == 0;
                }
            }
        }
    
        private final Sync sync;
    
        public CountDownLatch(int count) {
            if (count < 0) throw new IllegalArgumentException("count < 0");
            this.sync = new Sync(count);
        }
    
        public void await() throws InterruptedException {
            sync.acquireSharedInterruptibly(1);
        }
    
        public boolean await(long timeout, TimeUnit unit)
            throws InterruptedException {
            return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
        }
    
        public void countDown() {
            sync.releaseShared(1);
        }
    
        public long getCount() {
            return sync.getCount();
        }
    
        public String toString() {
            return super.toString() + "[Count = " + sync.getCount() + "]";
        }
    }
    

    从上面的代码可以看出来,CountDownLatch的Sync是实现了AQS,重写了 tryAcquireSharedtryReleaseShared ,都是在AQS的框架上来实现的队列。


    AQS是同步队列器,定义了一套锁的获取和释放,在 CountDownLatch 时并通过一个volatile的int类型state保存锁数量
    判断如果state为0表示无人占用,5就代表这个线程重入了5次,需要释放5次其他线程才可以获取到锁。

    AQS主要是判断当前共享空间为空时,则将当前请求资源设为有效运行,并把这个资源锁住。

    包括独占:ReentrantLock、共享:CountDownLatch

    ReentrantLock与Synchronized相似,不同之处是前者可实现公平锁,后者是隐式且非公平锁。

    CountDownLatch是一个计数器,countDown减少容器,await等待其他线程。

    ReentrantLock是独占锁,可重入,加锁和解锁需要手动进行,而且可被中断。


    2.CountDownLatch和CyclicBarrier区别

    CountDownLatch是等待别的线程准备完成后再一起运行

    而CyclicBarrier则是先运行线程,结束后再等一起进行下一步。

    3.Synchronized与ReentrantLock区别

    ReentrantLock是使用CAS来实现的

    而synchronized使用的是悲观并发策略

  • 相关阅读:
    wireshake抓包,飞秋发送信息,python
    python问题:IndentationError:expected an indented block错误解决《转》
    560. Subarray Sum Equals K
    311. Sparse Matrix Multiplication
    170. Two Sum III
    686. Repeated String Match
    463. Island Perimeter
    146. LRU Cache
    694. Number of Distinct Islands
    200. Number of Islands
  • 原文地址:https://www.cnblogs.com/nicori/p/14303388.html
Copyright © 2011-2022 走看看