java Semaphore

stefanieliang 发布于2019-08-16 17:45 / 3334人阅读

摘要：它可以设定一个阈值，基于此，多个线程竞争获取许可信号，做自己的申请后归还，超过阈值后，线程申请许可信号将会被阻塞。若该信号量保证在征用时按的顺序授予许可，则为，否则为例子餐厅个座位，但是有个人要等位就餐等位中。。。第个人吃完了。。

Semaphore简介

Semaphore是一种基于计数的信号量。它可以设定一个阈值，基于此，多个线程竞争获取许可信号，做自己的申请后归还，超过阈值后，线程申请许可信号将会被阻塞。Semaphore可以用来构建一些对象池，资源池之类的，比如数据库连接池，我们也可以创建计数为1的Semaphore，将其作为一种类似互斥锁的机制，这也叫二元信号量，表示两种互斥状态。它的用法如下：
availablePermits函数用来获取当前可用的资源数量
wc.acquire(); //申请资源
wc.release();// 释放资源

public Semaphore(int permits,boolean fair)
permits:初始化可用的许可数目。
fair: 若该信号量保证在征用时按FIFO的顺序授予许可，则为true，否则为false；

例子

餐厅2个座位，但是有3个人要等位就餐

public class SemaphoreThread extends Thread {
    private String name;
    private Semaphore semaphore;

    public SemaphoreThread(String name, Semaphore semaphore) {
        this.name = name;
        this.semaphore = semaphore;
    }

    @Override
    public void run() {
        if (semaphore.availablePermits() <= 0) {
            System.out.println(name + "等位中。。。");
        }
        try {
            semaphore.acquire();
            System.out.println(name + "开始就餐了。。");
            Thread.sleep(new Random().nextInt(1000));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(name + "吃完了。。");
        semaphore.release();
    }
}

请求：

@RequestMapping("test-semaphore")
    public void testSemaphore() {
        Semaphore semaphore = new Semaphore(2);
        for (int i = 1; i <= 3; i++) {
            new SemaphoreThread("第" + i + "个人", semaphore).start();
        }
    }

结果：
第1个人开始就餐了。。
第2个人开始就餐了。。
第3个人等位中。。。
第1个人吃完了。。
第3个人开始就餐了。。
第2个人吃完了。。
第3个人吃完了。。

云服务器服务器托管 Semaphore java初级java java怎么java java软件java

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

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

Java多线程工具箱之Semaphore

摘要：多线程工具箱之前言这一篇谈一下信号量。信息信息信息信息信息信息信息信息信息信息信息小结适用于多线程请求数量资源的场景，但无法解决单多个线程对同一资源访问的竞争性访问。在后面我们在我们的多线程工具箱里面陆续会提到。 Java多线程工具箱之Semaphore 前言这一篇谈一下Semaphore：信号量。将Semaphore类比为为信号灯，被继承Runable的线程类比为列车：理解信号量...

FleyX 2019-08-19 10:57 评论0 收藏0
Java多线程进阶（二十）—— J.U.C之synchronizer框架：Semaphore

摘要：当线程使用完共享资源后，可以归还许可，以供其它需要的线程使用。所以，并不会阻塞调用线程。立即减少指定数目的可用许可数。方法用于将可用许可数清零，并返回清零前的许可数六的类接口声明类声明构造器接口声明 showImg(https://segmentfault.com/img/bVbfdnC?w=1920&h=1200); 本文首发于一世流云的专栏：https://segmentfault...

boredream 2019-08-19 10:54 评论0 收藏0
长文慎入-探索Java并发编程与高并发解决方案

摘要：所有示例代码请见下载于基本概念并发同时拥有两个或者多个线程，如果程序在单核处理器上运行多个线程将交替地换入或者换出内存这些线程是同时存在的，每个线程都处于执行过程中的某个状态，如果运行在多核处理器上此时，程序中的每个线程都所有示例代码,请见/下载于 https://github.com/Wasabi1234... showImg(https://upload-images.jians...

SimpleTriangle 2019-08-16 13:54 评论0 收藏0
java多线程信号量-semaphore

摘要：年月日上午阿里云消息服，队列消息发送以及消费的并发测试解析配置文件二者等价线程数并发数程序入口准备工作发送消息线程池一个计数信号量。但是，不使用实际的许可对象，只对可用许可的号码进行计数，并采取相应的行动。 package com.study.mq.aliyunmns; import java.io.BufferedInputStream; import java.io.FileIn...

zzbo 2019-08-14 17:03 评论0 收藏0
java并发编程学习之Semaphore

摘要：作用信号量，限制同一时间，访问特定资源的线程数量，以保证合理的使用特定资源。主要方法获取锁，如果没有获取到，就堵塞释放锁示例运行结果如下可以看出，每次执行都是个。如果把和注释掉，可以看的结果如下同一时间，都打印到了控制台。作用信号量，限制同一时间，访问特定资源的线程数量，以保证合理的使用特定资源。主要方法 acquire:获取锁，如果没有获取到，就堵塞 release:释放锁 ...

岳光 2019-08-16 18:32 评论0 收藏0