java并发编程学习9-同步器--信号量

Jokcy 发布于2019-08-15 13:26 / 2312人阅读

摘要：为了通过信号量，线程通过调用请求许可。许可的数目是固定的，由此限制了线程通过的数量。当设置为时默认也是，此类不对线程获取许可的顺序做任何保证。

【同步器

java.util.concurrent包包含几个能帮助人们管理相互合作的线程集的类。这些机制具有为线程直间的共用集结点模式提供的‘预制功能’。如果有一个相互合作的线程满足这些行为模式之一，那么应该直接使用提供的类库而不是显示的使用锁与条件的集合。

【信号量

一个信号量管理过个许可证。为了通过信号量，线程通过调用acquire()请求许可。其实没有实际的许可对象，信号连也仅仅是维护一个计数器。许可的数目是固定的，由此限制了线程通过的数量。当一个线程执行完之后，应该调用release()释放许可证，让其他线程有机会执行。事实上，任意一个线程都有可以释放任意个数的许可证，这可能会增加许可证的个数。所以我建议，如果不是非常明确的知道为什么要释放多个许可证，就一定是让获得许可证的线程是放一个许可证。

【常用方法

构造函数：
　　- Semaphore(int permits)：创建具有给定许可数和非公平设置的Semaphore
　　- Semaphore(int permits，boolean fair)：此类的构造方法可选地接受一个公平参数。当设置为 false 时(默认也是false)，此类不对线程获取许可的顺序做任何保证。特别地，闯入是允许的，也就是说可以在已经等待的线程前为调用 acquire() 的线程分配一个许可，从逻辑上说，就是新线程将自己置于等待线程队列的头部。当公平设置为 true 时，信号量保证对于任何调用获取方法的线程而言，都按照处理它们调用这些方法的顺序（即先进先出；FIFO）来选择线程、获得许可。注意，FIFO 排序必然应用到这些方法内的指定内部执行点。所以，可能某个线程先于另一个线程调用了 acquire，但是却在该线程之后到达排序点，并且从方法返回时也类似。

　　2. Semaphore还提供一些其他方法：

    - int availablePermits() ：返回此信号量中当前可用的许可证数。
    - int getQueueLength()：返回正在等待获取许可证的线程数。
    - boolean hasQueuedThreads() ：是否有线程正在等待获取许可证。
    - void reducePermits(int reduction) ：减少reduction个许可证。是个protected方法。
    - Collection getQueuedThreads() ：返回所有等待获取许可证的线程集合。是个protected方法。

当许可证的个数为1时，可以充当互斥锁使用。

【例子：只能同时有5个线程访问的信号量

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class SemaTest {

    public static void main(String[] args) throws InterruptedException {
        // 线程池
        ExecutorService exec = Executors.newFixedThreadPool(20);
        // 只能5个线程同时访问
        final Semaphore semp = new Semaphore(5);
        // 模拟20个客户端访问
        for (int index = 0; index < 20; index++) {
            final int NO = index;
            Runnable run = new Runnable() {
                public void run() {
                    try {
                        //记住这里需要使用while,如果直接用if判断，那么每个线程只有一次机会去尝试占有对象
                        while (1 == 1){
                            // 获取许可
                            if(semp.tryAcquire()) {
                                System.out.println(Thread.currentThread().getName() + " 【 Access: " + NO);
                                Thread.sleep(100);
                                // 访问完后，释放
                                semp.release();
                                System.out.println(Thread.currentThread().getName() + " 【 Release: " + NO);
                                System.out.println("----------------- 【 " + Thread.currentThread().getName() + "】" + semp.availablePermits());
                                break;
                            }else{
                                System.out.println(Thread.currentThread().getName() + " 【 NOT Access: " + NO);
                                Thread.sleep(100);
                            }
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            };
            exec.execute(run);
        }
        //让子线程有充分时间运行完
        Thread.sleep(1000);
        exec.shutdown();
    }
}

GPU云服务器云服务器 java并发编程信号量机制编程c语言 java学习编程学习java编程

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/68091.html

Java 多线程并发编程面试笔录一览

摘要：创建线程的方式方式一将类声明为的子类。将该线程标记为守护线程或用户线程。其中方法隐含的线程为父线程。恢复线程，已过时。等待该线程销毁终止。更多的使当前线程在锁存器倒计数至零之前一直等待，除非线知识体系图： showImg(https://segmentfault.com/img/bVbef6v?w=1280&h=960); 1、线程是什么？线程是进程中独立运行的子任务。 2、创建线...

bitkylin 2019-08-19 10:48 评论0 收藏0
java篇

摘要：多线程编程这篇文章分析了多线程的优缺点，如何创建多线程，分享了线程安全和线程通信线程池等等一些知识。中间件技术入门教程中间件技术入门教程，本博客介绍了 ESB、MQ、JMS 的一些知识... SpringBoot 多数据源 SpringBoot 使用主从数据源简易的后台管理权限设计从零开始搭建自己权限管理框架 Docker 多步构建更小的 Java 镜像 Docker Jav...

honhon 2019-08-15 13:43 评论0 收藏0
Java并发编程笔记（二）

摘要：本文探讨并发中的其它问题线程安全可见性活跃性等等。当闭锁到达结束状态时，门打开并允许所有线程通过。在从返回时被叫醒时，线程被放入锁池，与其他线程竞争重新获得锁。本文探讨Java并发中的其它问题：线程安全、可见性、活跃性等等。在行文之前，我想先推荐以下两份资料，质量很高：极客学院-Java并发编程读书笔记-《Java并发编程实战》线程安全《Java并发编程实战》中提到了太多的术语...

NickZhou 2019-08-15 14:19 评论0 收藏0
并发编程导论

摘要：并发编程导论是对于分布式计算并发编程系列的总结与归纳。并发编程导论随着硬件性能的迅猛发展与大数据时代的来临，并发编程日益成为编程中不可忽略的重要组成部分。并发编程复兴的主要驱动力来自于所谓的多核危机。并发编程导论是对于分布式计算-并发编程 https://url.wx-coder.cn/Yagu8 系列的总结与归纳。欢迎关注公众号：某熊的技术之路。 showImg(https://...

GeekQiaQia 2019-08-16 16:53 评论0 收藏0