VB.net 2010 视频教程 VB.net 2010 视频教程 python基础视频教程
SQL Server 2008 视频教程 c#入门经典教程 Visual Basic从门到精通视频教程
当前位置:
首页 > temp > 简明python教程 >
  • 线程同步器CountDownLatch(2)

); } public final void acquireSharedInterruptibly(int arg) throws InterruptedException { //当前线程被中断就抛出异常 if (Thread.interrupted()) throw new InterruptedException(); //查看计数器中的值是不是0,不过不是0,就进入AQS等待队列等待; if (tryAcquireShared(arg) < 0) doAcquireSharedInterruptibly(arg); } protected int tryAcquireShared(int acquires) { return (getState() == 0) ? 1 : -1; }
复制代码

 

三.countDown方法

复制代码
public void countDown() {
    sync.releaseShared(1);
}

public final boolean releaseShared(int arg) {
    //tryReleaseShared方法返回false,说明当前计数器的值减一成功
    //返回true,说明计数器的值此时为0,那就要唤醒因为调用了CountDownLatch而阻塞的线程
    if (tryReleaseShared(arg)) {
        doReleaseShared();
        return true;
    }
    return false;
}

protected boolean tryReleaseShared(int releases) {
    //一个无限循环
    for (;;) {
        //获取state的值
        int c = getState();
        //如果state为0,返回false
        if (c == 0)
            return false;
        //否则就把state减一然后用CAS更新到state
        int nextc = c-1;
        if (compareAndSetState(c, nextc))
            return nextc == 0;
    }
}
复制代码

 

四.getState方法

  这个方法获取计数器的值,其实就是获取AQS中的state的值;

复制代码
int getCount() {
    return getState();
}
protected final int getState() {
    return state;
}
复制代码

 

   其实CountDownLatch比较容易,功能和Thread的join方法一样,只不过更灵活,基于AQS实现,在初始化的时候设置state的值,当线程调用CountDownLatch的await方法的时候,当前线程就会被丢到AQS的阻塞队列挂起;然后当其他线程调用了countDown方法,其实就是将state减一,当state等于0的时候,就会唤醒所有因为调用await方法而阻塞的线程;

--------------以上皆原创,给未来的自己留下一点学习的痕迹!--------

相关教程
          
关于我们--广告服务--免责声明--本站帮助-友情链接--版权声明--联系我们       黑ICP备07002182号