Java核心-多线程-并发控制器-Semaphore信号量

  1. Semaphore是非常有用的一个多线程并发控制组件(Java还有CountDownLatch、CyclicBarrier、Exchanger多线程组件),它相当于是一个并发控制器,是用于管理信号量的。构造的时候传入可供管理的信号量的数值,这个数值就是控制并发数量的,就是同时能几个线程访问。我们需要控制并发的代码,执行前先通过acquire方法获取信号,执行后通过release归还信号 。每次acquire返回成功后,Semaphore可用的信号量就会减少一个,如果没有可用的信号,acquire调用就会阻塞,等待有release调用释放信号后,acquire才会得到信号并返回。
    private Semaphore semaphore = new Semaphore(3, true); #true时,使用公平策略,也就是是使用公平锁
    ps:注意这里信号量acquire方法和release方法是可以有参数的,表示获取/返还的信号量个数,如果不指定就是默认单个释放。
  2. Semaphore分为单值和多值两种
    • 单值的Semaphore管理的信号量只有1个,该信号量只能被1个,只能被一个线程所获得,意味着并发的代码只能被一个线程运行,这就相当于是一个互斥锁了。
    • 多值的Semaphore管理的信号量多余1个,主要用于控制并发数。
  3. 这种通过Semaphore控制并发并发数的方式和通过控制线程数来控制并发数的方式相比,粒度更小,因为Semaphore可以通过acquire方法和release方法来控制代码块的并发数。
  4. 在构造Semaphore对象时,同时可以控制并发时抢占锁的公平策略。在公平的锁上,线程按照他们发出请求的顺序获取锁,但在非公平锁上,则允许‘插队’:当一个线程请求非公平锁时,如果在发出请求的同时该锁变成可用状态,那么这个线程会跳过队列中所有的等待线程而获得锁。
  5. 非公平锁的效率高于公平锁,主要原因是,在恢复一个被挂起的线程与该线程真正运行之间存在着严重的延迟。
    ps.当持有锁的时间相对较长,应该使用公平锁。在这些情况下,插队带来的吞吐量提升可能不会出现。
  6. 使用示例,模仿上厕所排队的例子
 package common_test;
import java.util.Random;
import java.util.concurrent.*;

public class SemaphoreTest {

    private Semaphore semaphore = new Semaphore(3, true);
    private Random random = new Random();

    class Task implements Runnable{
        private String id;
        public Task(String id){
            this.id = id;
        }
        public void run() {
            try {
                semaphore.acquire();
                System.out.println("茅坑" + id + " 被占用了");
                work();
                System.out.println("茅坑" + id + " 空了");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }finally{
                semaphore.release();
            }
        }

        public void work(){
            int worktime = random.nextInt(1000);
                    System.out.println("茅坑  " + id + "使用了"+ worktime + "秒");
            try {
                Thread.sleep(worktime);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) {
            SemaphoreTest semaphoreTest = new SemaphoreTest();
            ExecutorService newCachedThreadPool = Executors.newCachedThreadPool();
            newCachedThreadPool.submit(semaphoreTest.new Task(1+""));
            newCachedThreadPool.submit(semaphoreTest.new Task(2+""));
            newCachedThreadPool.submit(semaphoreTest.new Task(3+""));
            newCachedThreadPool.submit(semaphoreTest.new Task(4+""));
            newCachedThreadPool.submit(semaphoreTest.new Task(5+""));
            newCachedThreadPool.submit(semaphoreTest.new Task(6+""));
            newCachedThreadPool.submit(semaphoreTest.new Task(7+""));
            newCachedThreadPool.shutdown();
        }
}

原文地址:https://www.cnblogs.com/leeethan/p/10556217.html

时间: 2024-11-05 22:46:04

Java核心-多线程-并发控制器-Semaphore信号量的相关文章

java 多线程 28 : 多线程组件之 Semaphore 信号量

Semaphore是非常有用的一个组件,它相当于是一个并发控制器,是用于管理信号量的.构造的时候传入可供管理的信号量的数值,这个数值就是控制并发数量的,就是同时能几个线程访问.我们需要控制并发的代码,执行前先通过acquire方法获取信号,执行后通过release归还信号 .每次acquire返回成功后,Semaphore可用的信号量就会减少一个,如果没有可用的信号,acquire调用就会阻塞,等待有release调用释放信号后,acquire才会得到信号并返回. ps:注意这里信号量acqui

Java学习笔记--并发工具Semaphore,CountDownLatch,CyclicBarrier,Exchanger

Semaphore 实现典型的信号量 CountDownLatch 在指定数量的事件发生前一直等待 CyclicBarrier 使一组线程在一个预定义的执行点等待 Exchanger 交换两个线程的数据 1. Semaphore 信号量(Semaphore),是在多线程环境下使用的一种设施, 它负责协调各个线程, 以保证它们能够正确.合理的使用公共资源 在java中,还可以设置该信号量是否采用公平模式,如果以公平方式执行,则线程将会按到达的顺序(FIFO)执行,如果是非公平,则可以后请求的有可能

java核心-多线程(8)- 并发原子类

????使用锁能解决并发时线程安全性,但锁的代价比较大,而且降低性能.有些时候可以使用原子类(juc-atomic包中的原子类).还有一些其他的非加锁式并发处理方式,我写这篇文章来源于Java中有哪些无锁技术来解决并发问题的思考. 1.原子类场景 刚才说了,原子类是在不加锁的情况下,实现并发安全.我们知道锁synchronized/lock能实现并发安全的三点要求:原子性.可见性和有序性.而原子类顾名思义可以保证原则性其他两点不能确定(我是边想边写的,后面我会给出结论). 好吧,写不下去了,还是

[Java复习] 多线程 并发 JUC 补充

线程安全问题? 当多个线程共享同一个全局变量,做写的操作时,可能会受到其他线程的干扰.读不会发生线程安全问题. --  Java内存模型. 非静态同步方法使用什么锁? this锁 静态同步方法使用什么锁? 当前类的字节码文件 什么是ThreadLocal? ThreadLocal是给每个线程提供局部变量,每个线程可独立改变自己的副本,不会影响其他线程所对应的副本,解决线程安全问题. ThreadLocal底层原理是map集合. ThreadLocal内存泄漏问题? 由于ThreadLocalMa

java核心-多线程(4)-线程类基础知识

1.并发 <1>使用并发的一个重要原因是提高执行效率.由于I/O等情况阻塞,单个任务并不能充分利用CPU时间.所以在单处理器的机器上也应该使用并发. <2>为了实现并发,操作系统层面提供了.但是进程的数量和开销都有限制,并且多个进程之间的数据共享比较麻烦.另一种比较轻量的并发实现是使用线程,一个进程可以包含多个线程.线程在进程中没有数量限制, 数据共享相对简单.线程的支持跟语言是有关系的.Java 语言中支持多线程. <3>Java 中的多线程是抢占式的.这意味着一个任

[笔记][Java7并发编程实战手册]3.2 资源的并发访问控制Semaphore信号量

[笔记][Java7并发编程实战手册]系列目录 简介 本文学习信号量Semaphore机制. Semaphore 本质是一个共享锁 内部维护一个可用的信号集,获取信号量之前需要先申请获取信号数量:用完之后,则需要释放信号量:如果不释放,那么其他等待线程则一直阻塞直到获取信号量或则被中断为止 本人的理解是:互斥锁是同一时间只能一个线程访问,而在这里,是同一时间允许获取到了信号量的线程并发访问,而没有获取到信号量的则必须等待信号量的释放: 将信号量初始化为 1,使得它在使用时最多只有一个可用的许可,

Java接口多线程并发测试 (二)

原文地址http://www.cnblogs.com/yezhenhan/archive/2012/01/09/2317636.html 这是一篇很不错的文章,感谢原博主的分享! JAVA多线程实现和应用总结 最近在做代码优化时学习和研究了下JAVA多线程的使用,看了菜鸟们的见解后做了下总结.1.JAVA多线程实现方式JAVA多线程实现方式主要有三种:继承Thread类.实现Runnable接口.使用ExecutorService.Callable.Future实现有返回结果的多线程.其中前两种

Java实现多线程并发

1 import java.util.concurrent.ExecutorService; 2 import java.util.concurrent.Executors; 3 import java.util.concurrent.Semaphore; 4 5 public class ThreadTest { 6 private static int thread_num = 500; 7 private static int client_num = 5000; 8 9 public s

java多线程并发编程与CPU时钟分配小议

我们先来研究下JAVA的多线程的并发编程和CPU时钟振荡的关系吧 老规矩,先科普 我们的操作系统在DOS以前都是单任务的 什么是单任务呢?就是一次只能做一件事 你复制文件的时候,就不能重命名了 那么现在的操作系统,我一边在这边写BLOG,一边听歌,一边开着QQ,一边…………………… 显然,现在的操作系统都是多任务的操作系统 操作系统对多任务的支持是怎么样的呢? 每打开一个程序,就启动一个进程,为其分配相应空间(主要是运行程序的内存空间) 这其实就支持并发运行了 CPU有个时钟频率,表示每秒能执行