Java并发编程的艺术(八)——闭锁、同步屏障、信号量详解

1. 闭锁:CountDownLatch

1.1 使用场景

若有多条线程,其中一条线程需要等到其他所有线程准备完所需的资源后才能运行,这样的情况可以使用闭锁。

1.2 代码实现

// 初始化闭锁,并设置资源个数
CountDownLatch latch = new CountDownLatch(2);

Thread t1 = new Thread( new Runnable(){
    public void run(){
        // 加载资源1
        加载资源的代码……
        // 本资源加载完后,闭锁-1
        latch.countDown();
    }
} ).start();

Thread t2 = new Thread( new Runnable(){
    public void run(){
        // 加载资源2
        资源加载代码……
        // 本资源加载完后,闭锁-1
        latch.countDown();
    }
} ).start();

Thread t3 = new Thread( new Runnable(){
    public void run(){
        // 本线程必须等待所有资源加载完后才能执行
        latch.await();
        // 当闭锁数量为0时,await返回,执行接下来的任务
        任务代码……
    }
} ).start();

2. 同步屏障:CyclicBarrier

2.1 使用场景

若有多条线程,他们到达屏障时将会被阻塞,只有当所有线程都到达屏障时才能打开屏障,所有线程同时执行,若有这样的需求可以使用同步屏障。此外,当屏障打开的同时还能指定执行的任务。

2.2 闭锁 与 同步屏障 的区别

  • 闭锁只会阻塞一条线程,目的是为了让该条任务线程满足条件后执行;
  • 而同步屏障会阻塞所有线程,目的是为了让所有线程同时执行(实际上并不会同时执行,而是尽量把线程启动的时间间隔降为最少)。

2.3 代码实现

// 创建同步屏障对象,并制定需要等待的线程个数 和 打开屏障时需要执行的任务
CyclicBarrier barrier = new CyclicBarrier(3,new Runnable(){
    public void run(){
        //当所有线程准备完毕后触发此任务
    }
});

// 启动三条线程
for( int i=0; i<3; i++ ){
    new Thread( new Runnable(){
        public void run(){
            // 等待,(每执行一次barrier.await,同步屏障数量-1,直到为0时,打开屏障)
            barrier.await();
            // 任务
            任务代码……
        }
    } ).start();
}

3. 信号量:Semaphore

3.1 使用场景

若有m个资源,但有n条线程(n>m),因此同一时刻只能允许m条线程访问资源,此时可以使用Semaphore控制访问该资源的线程数量。

3.2 代码实现

// 创建信号量对象,并给予3个资源
Semaphore semaphore = new Semaphore(3);

// 开启10条线程
for ( int i=0; i<10; i++ ) {
    new Thread( new Runnbale(){
        public void run(){
            // 获取资源,若此时资源被用光,则阻塞,直到有线程归还资源
            semaphore.acquire();
            // 任务代码
            ……
            // 释放资源
            semaphore.release();
        }
    } ).start();
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java学习123

linux mount -t用法

1.8K50
来自专栏小狼的世界

CentOs5.2中PHP的升级

最近一个项目中需要使用到PHP5.2的版本,而服务器上使用了官方的yum源进行安装,默认的版本是5.1.6,需要升级。但是因为不是一个非常正式的服务器环境,所以...

11230
来自专栏coding...

Jenkins + Android 自动化打包 发布到蒲公英写在前面准备工作新建任务签名配置一些报错

最先想到的方案当然就是跟iOS一样使用fastlane,查了下相关资料发现fastlane有点重iOS轻Android,于是放弃。找到代替方案,直接使用grad...

12810
来自专栏python3

Centos7 安装python虚拟环境+Django

鉴于virtualenv不便于对虚拟环境集中管理,所以推荐直接使用virtualenvwrapper。 virtualenvwrapper提供了一系列命令使得和...

29920
来自专栏Phoenix的Android之旅

Dagger2 Android应用:接入

网上不少资源说要在Project和module下的build.gradle分别添加以下依赖,然而是错的

9620
来自专栏Java学习网

spring在ssh框架中的作用学习

spring在ssh框架中的作用学习 在SSH框假中spring充当了管理容器的角色。我们都知道Hibernate用来做持久层,因为它将JDBC做...

25590
来自专栏c#开发者

android studio 更新 Gradle错误解决方法

Android Studio每次更新版本都会更新Gradle这个插件,但由于长城的问题每次更新都是失败,又是停止在Refreshing Gradle Proje...

33370
来自专栏全栈之路

vscode配置go环境

假设目录为/Users/<用户名>/Documents/go-test,添加环境变量:

1.9K30
来自专栏WindCoder

springBoot+gradle构建多模块项目

提示:若先配置settings文件无法触发自动构建,请先执行下一步“修改根目录 build.gradle”,之后保存就会自动执行。

1.9K20
来自专栏灯塔大数据

15 个 Android 通用流行框架大全

? 1 缓存 名称描述DiskLruCacheJava实现基于LRU的磁盘缓存 2 图片加载 名称描述Android Universal Image Lo...

32660

扫码关注云+社区

领取腾讯云代金券