java exchanger 应用场景_java多线程系列:Semaphore和Exchanger
本篇文章将介绍Semaphore和Exchanger这两个并发工具类。
Semaphore信号量(英语:Semaphore)又称为信号标,是一个同步对象,用于保持在0至指定最大值之间的一个计数值。当线程完成一次对该semaphore对象的等待(wait)时,该计数值减一;当线程完成一次对semaphore对象的释放(release)时,计数值加一。当计数值为0,则线程等待该semaphore对象不再能成功直至该semaphore对象变成signaled状态。semaphore对象的计数值大于0,为signaled状态;计数值等于0,为nonsignaled状态.
semaphore对象适用于控制一个仅支持有限个用户的共享资源,是一种不需要使用忙碌等待(busy waiting)的方法。 ----取自维基百科
Semaphore思想在分布式中也有应用,分布式限流就是典型的案例。现在举个小例子来使用Semaphore
案例
在等公交时,遇到人多的时候经常需要排队或者挤进去。
解决方案
利用Semaphore初始化5个许可,每次只能有5个玩家进入,当有玩家退出时,其他玩家才能进入。
先介绍下Semaphore的构造函数和一些方法吧。
Semaphore构造函数public Semaphore(int permits);public Semaphore(int permits, boolean fair);
第一个参数permits表示初始化的许可数量,第二个参数表示是否是公平的。使用Semaphore(int permits)构造函数时,默认使用非公平的
Semaphore常用方法public void acquire();public void release();
acquire方法取得许可,release方法表示释放许可。注:如果多次调用release方法,会增加许可。例如,初始化许可为0,这时调用了两个release方法,Semaphore的许可便会变成2
这两个是最常用的方法,其他的还有acquire相关的方法tryAcquire和acquireUninterruptibly这里就不介绍了。
代码
玩家类
定义一个实现Runnable接口的玩家类public class Player implements Runnable{ private String playerName; private Semaphore semaphore; public Player(String playerName, Semaphore semaphore) { this.playerName = playerName; this.semaphore = semaphore;
} @Override
public void run() { try {
semaphore.acquire();
System.out.println(playerName+"进入,时间:"+LocalTime.now());
Thread.sleep((long) (3000 * Math.random()));
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
System.out.println(playerName+"退出");
semaphore.release();
}
}
}
通过构造函数Player传入玩家名称和Semaphore对象,run方法中先调用acquire方法取得许可,然后睡眠随机时间,最后在finally中调用release方法释放许可。
测试类
先来使用非公平的看看效果,使用非公平的就好比平时的挤公交,谁先在车门口谁先进。如下图(来源于网络)
现在来看看测试代码public static void main(String[] args) throws IOException {
Semaphore semaphore = new Semaphore(5); //Semaphore semaphore = new Semaphore(5,true);
ExecutorService service = Executors.newCachedThreadPool(); //模拟100个玩家排队
for (int i = 0; i
service.submit(new Player("玩家"+i,semaphore));
} //关闭线程池
service.shutdown(); //判断线程池是否中断,没有则循环查看当前排队总人数
while (!service.isTerminated()){
System.out.println("当前排队总人数:"+semaphore.getQueueLength()); try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
如果要切换成公平方式只需将上面初始化Semaphore改为下面的代码即可Semaphore semaphore = new Semaphore(5,true);
Exchanger
Exchanger主要用于线程间的数据交换。 它提供了一个同步点,在这个同步点,两个线程可以交换数据。
这里写了个两个线程互相交换数据的简单例子,下面ExchangerRunnable在run方法中调用exchange方法将自己的数据传过去。public class ExchangerRunnable implements Runnable { private Object data; private String name; private Exchanger exchanger; public ExchangerRunnable(String name, Exchanger exchanger, Object data) { this.exchanger = exchanger; this.name = name; this.data = data;
} public void run() { try {
Object previous = this.data; this.data = this.exchanger.exchange(previous);
System.out.println("名称:" + name + " 之前数据:" + previous + " ,交换之后数据:" + this.data);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
接下来看看测试代码public class Case { private static final Exchanger exchanger = new Exchanger(); private static ExecutorService service = Executors.newFixedThreadPool(2); public static void main(String[] args) {
service.submit(new ExchangerRunnable("1", exchanger, "A"));
service.submit(new ExchangerRunnable("2", exchanger, "B"));
service.shutdown();
}
}
定义了只包含两个线程的线程池,然后创建提交两个ExchangerRunnable的类线程名称为1的原始数据时A
线程名称为2的原始数据时B
运行测试代码,会得到如下结果名称:2 之前数据:B ,交换之后数据:A名称:1 之前数据:A ,交换之后数据:B
欢迎fork、Star、Issue等,谢谢
作者: 云枭zd
Github: Github地址
出处: https://www.cnblogs.com/fixzd/
版权声明:本文欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则视为侵权。
java exchanger 应用场景_java多线程系列:Semaphore和Exchanger相关推荐
- java线程 教程_Java多线程系列教程
Java多线程系列教程 多线程是Java中不可避免的一个重要主体.从本章开始,我们将展开对多线程的学习.接下来的内容是对Java多线程内容的讲解,涉及到的内容包括,Object类中的wait(), n ...
- java线程池 锁_java多线程——锁
这是多线程系列第四篇,其他请关注以下: 如果你看过前面几篇关于线程的文字,会对线程的实现原理了然于胸,有了理论的支持会对实践有更好的指导,那么本篇会偏重于线程的实践,对线程的几种应用做个简要的介绍. ...
- java线程代码实现_Java 多线程代码实现讲解
作为一个完全面向对象的语言,Java提供了类 java.lang.Thread 来方便多线程编程,这个类提供了大量的方法来方便我们控制自己的各个线程.那么如何提供给 Java 我们要线程执行的代码呢? ...
- java多线程工具类_Java多线程系列之:线程的并发工具类
一,Fork-Join 1,定义: Fork-Join框架:就是在必要的情况下,将一个大任务,进行拆分(fork)成若干个小任务(拆到不能再拆时),再将一个个的小任务运算的结果进行join汇总. 2, ...
- java futher多线程_Java多线程系列--“JUC集合”05之 ConcurrentSkipListMap
概要 本章对Java.util.concurrent包中的ConcurrentSkipListMap类进行详细的介绍.内容包括: ConcurrentSkipListMap介绍 ConcurrentS ...
- java多线程使用业务场景_Java多线程使用场景
一.几个基本概念的区分 1.进程与程序的区分 程序 进程 包含代码部分.数据部分 包含代码部分.数据部分.进程控制块 顺序执行 并发执行 独占资源 共享资源 同步的 异步的 静态的 动态的 (本质区别 ...
- java多线程的join方法_java多线程系列_join方法的使用(5)
在上面的例子中多次使用到了Thread类的join方法.我想大家可能已经猜出来join方法的功能是什么了.对,join方法的功能就是使异步执行的线程变成同步执行.也就是说,当调用线程实例的start方 ...
- java进程与线程_Java多线程笔记(零):进程、线程与通用概念
前言 不积跬步,无以至千里:不积小流,无以成江海.在学习Java多线程相关的知识前,我们首先需要去了解一点操作系统的进程.线程以及相关的基础概念. 进程 通常,我们把一个程序的执行称为一个进程.反过来 ...
- java线程集合点_Java多线程学习笔记(三) 甚欢篇
使人有乍交之欢,不若使其无久处之厌 <小窗幽记>很多时候,我们需要的都不是再多一个线程,我们需要的线程是许多个,我们需要让他们配合.同时我们还有一个愿望就是复用线程,就是将线程当做一个工人 ...
最新文章
- 系统架构领域的一些学习材料
- C# 3.0实现类本身的方法扩展
- python子类定制_在Python中实现可定制的Lexer类
- 数据库杂谈(六)——数据库管理系统
- 用了都说好的SCI在线绘图工具来了~~~~~~~
- 信息学奥赛一本通C++语言——1077:统计满足条件的4位数
- 每日算法系列【LeetCode 1031】两个非重叠子数组的最大和
- Hello!SCDN
- 普中科技51单片机-单核-A2开发板实现简易计算器功能(矩阵键盘操作+数码管显示)
- 北京市海淀区土地利用总体规划(2006-2020)(zz.is2120.BG57IV3)
- androidFD泄露问题总结
- TD-SCDMA牵动3G牌照发放 重塑中国电信生态
- 南阳oj 题目127 星际之门(一)
- 内存管理(二) - MRC关键字解读
- ubuntu mysql快捷键_ubuntu快捷键设置大全
- sourceTree使用详解
- 南宁市计算机技术专业学校,南宁电脑技术学校有哪些
- [ESP][驱动]ST7701S RGB屏幕驱动
- 基于PHP+MySQL音乐相册网站的设计与实现
- 白话中台战略2:中台到底长啥样?