JUC(java.util.concurrent)的常见类(多线程编程常用类)

Callable接口

这个东西可以类比于之前见过的Runnable接口.两者的区别在于Runnable关注执行过程,不关注执行结果.Callable关注执行结果,它之中的call方法(类比于run方法)返回值就是线程执行任务的结果.Callable<V>里面的V期望线程的入口方法里,返回值是啥类型,此处的泛型参数就是啥类型.

Callable优势

示例:创建线程计算1+2+...+1000,使用Runnable版本

public class ThreadDemo7 {private static int sum = 0;public static void main(String[] args) throws InterruptedException {Thread t = new Thread(new Runnable() {@Overridepublic void run() {int result = 0;for(int i = 0; i <= 1000; i++) {result += i;}sum = result;}});t.start();t.join();//主线程获取到计算结果//此处要想获取到结果,就需要专门搞一个成员变量保存上述的计算结果System.out.println("sum =" + sum);}
}

这么做虽然能够解决问题,但是代码不是很优雅,这时我们就希望依靠返回值来直接保存计算结果,

这就用到了Callable接口,使用流程如下:

 1.创建一个匿名内部类,实现Callable接口.Callable带有泛型参数.泛型参数表示返回值的类型

2.重写Callable的call方法,完成累加的过程,直接通过返回值返回计算结果

3.把callable示例用FutureTask包装一下.

4.创建线程,线程的构造方法传入FutureTask.此时新线程就会执行FutureTask内部的Callable的call方法,完成计算.计算结果就放进了FutureTask对象中.

5.在主线程中调用futureTask.get()能够阻塞等待新线程计算完毕.并获取FutureTask中的结果.

代码如下:

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
public class ThreadDemo8 {public static void main(String[] args) throws ExecutionException, InterruptedException {Callable<Integer> callable = new Callable<Integer>() {@Overridepublic Integer call() throws Exception {int result = 0;for(int i = 0; i <= 1000; i++) {result += i;}return result;}};FutureTask<Integer> futureTask = new FutureTask<>(callable);Thread t = new Thread(futureTask);t.start();//接下来这个代码也不需要join,使用futureTask获取到结果.//get()方法具有阻塞功能.如果线程不执行完毕,get就会阻塞//等到线程执行完了,return的结果,就会被get返回回来System.out.println(futureTask.get());}
}

可以看到,使用Callable和FutureTask之后,代码简化了很多,也不必手动写线程同步代码了.

理解Callable

Callable通常需要搭配FutureTask来使用.FutureTask用来保存Callable的返回结果.因为Callable往往是在另一个线程中执行的,什么时候执行完并不确定. 

FutureTask就可以负责这个等待结果出来的工作.

理解FutureTask

FutureTask即未来的任务,既然这个任务是在未来执行完毕,最终取结果时就需要一张凭证.

可以想象成去吃麻辣烫.当餐点好后,后厨就开始做了.同时前台会给你一张小票.这个小票就是FutureTask.后面我们可以随时凭这张小票去查看自己的这份麻辣烫做出来没.

总结:创建线程的方式:1.继承Thread(包含匿名内部类).2.实现Runnable(包含匿名内部类).

3.基于lambda. 4.基于Callable. 5.基于线程池.

ReentrantLock

可重入互斥锁.和synchronized定位类似,都是用来实现互斥效果,保证线程安全.

ReentrantLock也是可重入锁."Reentrant"这个单词的原意就是"可重入".

ReentrantLock的用法:

lock():加锁,如果获取不到锁就死等.

trylock(超时时间):加锁,如果获取不到锁,等待一定时间之后就放弃加锁.(此处通过trylock提供了更多的可操作空间)

unlock():解锁

ReentrantLock lock = new ReentrantLock();
-----------------------------------------lock.lock();
try {//working...
} finally {lock.unlock()
}

 ReentrantLock和synchronized的区别

通过上述解释,我们不免发现ReentrantLock和Synchronized非常相像,下面来说一说他们的区别:

1.synchronized是一个关键字,是JVM内部实现的(大概率是基于C++实现).ReentrantLock是标准库中的一个类,在JVM外实现的(基于Java实现).

2.synchronized使用时不需要手动释放锁.ReentrantLock使用时需要手动释放.使用起来更灵活,但是也容易遗漏unlock.

3.synchronized在申请失败时,会死等.ReentrantLock可以通过trylock的方式等待一段时间后就放弃

4.synchronized是非公平锁,ReentrantLock默认是非公平锁.可以通过一个构造方法传入一个true进入公平锁模式(原理:通过队列记录加锁线程的先后顺序).

//ReentrantLock的构造方法
public ReentrantLock(boolean fair) {sync = fair ? new FairSync() : new NonfairSync();
}

5.搭配的等待通知机制是不同的

对于synchronize,搭配wait/notify

对于ReentrantLock,搭配Condition类,功能比wait,notify略强一些.

如何选择使用哪个锁

1.锁竞争不激烈时,使用synchronized,效率更高,自动释放更方便.

2.锁竞争激烈时,搭配trylock更灵活控制锁的行为,而不是死等

3.如果需要使用公平锁,使用ReentrantLock.

其实,一般情况下会使用synchronized即可.

信号量Semaphore

信号量,用来表示"可用资源的个数".本质上就是一个计数器.

理解信号量(想象成一个更广义的锁)

可以把信号量想象成是停车场的展示牌:当前有车位100个.表示有100个可用资源.

当有车开进去的时候,就相当于申请(acquire)一个可用资源,可用车位就-1.(这称为信号量的P操作)

当有车开出来的时候,就相当于释放(release)一个可用资源,可用车位就+1.(这称为信号量的V操作)

如果计数器的值已经为0了,还尝试申请资源,就会堵塞等待,直到有其它线程释放资源.

Semaphore的PV操作中的加减计数器操作都是原子的,可以在多线程下直接使用.

所谓锁本质也是一种特殊的信号量.锁可以认为就是计数值为1的信号量,释放状态就是1,加锁状态就是0.对于这种非0即1的信号量.称为"二元信号量".

代码示例:

1.创建Semaphore示例,初始化为4,表示有4个可用资源.

2.acquire方法表示申请资源(P操作),release方法表示释放资源(V操作).

3.创建20个线程,每个线程都尝试申请资源,sleep一秒之后,释放资源,观察程序的执行效果.

import java.util.concurrent.Semaphore;public class ThreadDemo9 {public static void main(String[] args) {Semaphore semaphore = new Semaphore(4);Runnable runnable = new Runnable() {@Overridepublic void run() {try {System.out.println("申请资源");semaphore.acquire();System.out.println("我获取到资源了");Thread.sleep(1000);System.out.println("我释放资源了");semaphore.release();} catch (InterruptedException e) {e.printStackTrace();}}};for(int i = 0; i < 10; i++) {Thread t = new Thread(runnable);t.start();}}
}

 总结:如何保证线程安全

1.synchronized

2.Reentrantlock

3.CAS(原子类)

4.Semaphore (也可以用于实现生产者消费者模型:

定义两个信号量:一个用来表示队列中有多少个可以消费的元素sem1,另一个用于表示队列中有多少个可放置新元素的空间sem2.

生产:sem1.V(),sem2.P()

消费:sem1.P(),sem2.V()

CountDownLatch

同时等待N个任务执行结束.(多线程中执行一个任务,把大的任务分为几个部分,由每个线程分别执行).

就好像跑步比赛,10个选手依次就位,哨声响了才能同时出发;所有选手都通过终点,才能公布成绩.

1.构造CountDownLatch实例,初始化10表示有10个任务需要完成.

2.每个任务执行完毕,都调用latch.countDown().在CountDownLatch1内部的计数器同时自减

3.主线程中使用latch.await();阻塞等待所有任务执行完毕.相当于计数器为0了.

import java.util.Random;
import java.util.concurrent.CountDownLatch;public class ThreadDemo10 {public static void main(String[] args) throws InterruptedException {CountDownLatch latch = new CountDownLatch(10);Runnable r = new Runnable() {@Overridepublic void run() {Random random = new Random();int x = random.nextInt(5) + 1;try {Thread.sleep(x * 1000);latch.countDown();} catch (InterruptedException e) {throw new RuntimeException(e);}}};for(int i = 0; i < 10; i++) {new Thread(r).start();}//必须等到所有线程全部结束latch.await();System.out.println("比赛结束");}
}

相关面试题

1.线程同步的方式有哪些?

synchronized, ReentrantLock, Semaphore等都用于线程同步.

2.为什么有了synchronized还需要juc下的lock?

以juc的ReentrantLock为例,

synchronized使用时不需要手动释放锁.ReentrantLock使用时需要通过手动释放,使用起来更加灵活.

synchronized在申请失败后会死等.ReentrantLock可以通过trylock的方式等待一段时间就放弃.

synchronized是非公平锁,ReentrantLock默认是非公平锁.可以通过构造方法传入一个true开启公平锁模式

synchronized是通过Object的wait/notify实现等待-唤醒.每次唤醒的是一个随机等待的线程.ReentrantLock搭配Condition类实现等待-唤醒,可以更精确的控制唤醒某个指定的线程.

3.信号量听说过吗?都用于哪些场景下?

信号量,用来表示"可用资源的个数",本质上就是一个计数器.

使用信号量可以实现"共享锁",比如某个资源允许3个线程同时使用,那么就可以使用P操作加锁,V操作为解锁,前三个线程的P操作都能顺利返回,后续再进行P操作就会阻塞等待,直到前面的线程执行了V操作.

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/630536.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Servlet中访问网页常遇到的问题

网页出现404 出现这一种情况是浏览器访问的资源不存在 第一种情况通常是路径出错请检查你的路径是否一致 第二种情况确认你的webapp是否被正确加载 smart tomcat由于只加载一个webapp 如果加载失败 就会直接启动失败 拷贝war方式到Tomcat要加载多个webapp如果失败只有日志 查…

软件测试|sqlalchemy relationship

简介 SQLAlchemy是一个流行的Python ORM&#xff08;对象关系映射&#xff09;库&#xff0c;它允许我们以面向对象的方式管理数据库。在SQLAlchemy中&#xff0c;relationship是一个重要的功能&#xff0c;用于建立表之间的关系。在本文中&#xff0c;我们将详细探讨relation…

AutoRuns下载安装使用教程(图文教程)超详细

「作者简介」&#xff1a;CSDN top100、阿里云博客专家、华为云享专家、网络安全领域优质创作者 「推荐专栏」&#xff1a;对网络安全感兴趣的小伙伴可以关注专栏《网络安全入门到精通》 AutoRuns 是微软提供的一款「启动项管理」工具&#xff0c;可以检查开机自动加载的所有程…

UI设计中插画赏析和产品色彩分析

插画赏析&#xff1a; 1. 插画是设计的原创性和艺术性的基础 无论是印刷品、品牌设计还是UI界面&#xff0c;更加风格化的插画能够将不同的风格和创意加入其中&#xff0c;在激烈的竞争中更容易因此脱颖而出。留下用户才有转化。 2. 插画是视觉触发器&#xff0c;瞬间传达大量…

Effective C++——尽可能使用const

const允许指定一个语义约束&#xff08;也就是指定一个“不该被改动”的对象&#xff09;&#xff0c;而编译器会强制实施这项约束。只要保持某个值不变是事实&#xff0c;就应该说出来。以获得编译器的协助&#xff0c;保证不被违反。 const与指针 注意const的写法&#xff0…

国产阿里的Copilot能提效30%吗?

国产阿里的Copilot能提效30%吗&#xff1f; Copilot简介 GitHub 和 OpenAI 共同打造的一款编程神器–Copilot&#xff0c; 这是一款立足于人工智能技术的编程助手。在此基础上&#xff0c;借助于 GitHub 庞大的代码库和来自全球的开源社区帮助&#xff0c;搭配 OpenAI 在自然…

[原创][R语言]股票分析实战[11]:读取股票数据文件的细节: 提取目标列数据

[简介] 常用网名: 猪头三 出生日期: 1981.XX.XX QQ联系: 643439947 个人网站: 80x86汇编小站 https://www.x86asm.org 编程生涯: 2001年~至今[共22年] 职业生涯: 20年 开发语言: C/C、80x86ASM、PHP、Perl、Objective-C、Object Pascal、C#、Python 开发工具: Visual Studio、D…

cookie和session的工作过程和作用:弥补http无状态的不足

cookie是客户端浏览器保存服务端数据的一种机制。当通过浏览器去访问服务端时&#xff0c;服务端可以把状态数据以key-value的形式写入到cookie中&#xff0c;存储到浏览器。浏览器下次去服务服务端时&#xff0c;就可以把这些状态数据携带给服务器端&#xff0c;服务器端可以根…

elasticsearch查询

&#xff08;1&#xff09;简单查询 curl -XGET http://127.0.0.1:9201/_search curl -XGET http://127.0.0.1:9201/test231208/_search curl -XGET http://127.0.0.1:9201/test231208/_doc/_search curl -XGET http://127.0.0.1:9201/test231208/_doc/id &#xff08;2&…

【centos7系统】Redis-6.2.2版本集群搭建

转载说明&#xff1a;如果您喜欢这篇文章并打算转载它&#xff0c;请私信作者取得授权。感谢您喜爱本文&#xff0c;请文明转载&#xff0c;谢谢。 前redis最新版本已经是6.2.4&#xff0c;在集群搭建上和redis3.x、redis4.x区别很大。redis5以后&#xff0c;就不需要安装ruby了…

腾讯云主机优惠价格表(2024新版报价)

腾讯云服务器租用价格表&#xff1a;轻量应用服务器2核2G3M价格62元一年、2核2G4M价格118元一年&#xff0c;540元三年、2核4G5M带宽218元一年&#xff0c;2核4G5M带宽756元三年、轻量4核8G12M服务器446元一年、646元15个月&#xff0c;云服务器CVM S5实例2核2G配置280.8元一年…

vue3深入组件: 组件注册

组件注册 一个 Vue 组件在使用前需要先被“注册”&#xff0c;这样 Vue 才能在渲染模板时找到其对应的实现。组件注册有两种方式&#xff1a;全局注册和局部注册。 全局注册 我们可以使用 Vue 应用实例的.component()方法&#xff0c;让组件在当前 Vue 应用中全局可用。 im…

Cpp多线程(一)

一、基本概念 1、程序是一段静态代码&#xff1b;进程是正在运行的程序&#xff1b;线程则是程序内部的执行路径。 上面这张图就解释了线程和多线程的意义。 2、若一个程序在同一时间执行多个线程&#xff0c;便是支持多线程的。一个进程中的多个线程共享相同的内存单元/内存…

linux设置定时任务

在Linux系统中设置定时任务通常使用的是Cron服务。以下是创建和管理定时任务的基本步骤&#xff1a; 打开crontab文件编辑器&#xff1a; 使用命令行工具编辑用户级别的cron任务列表&#xff1a; crontab -e 这将使用默认文本编辑器打开当前用户的crontab文件。 添加定时任务&…

[分布监控平台] Zabbis 监控

zabbix 是什么&#xff1f; zabbix 是一个基于 Web 界面的提供分布式系统监视以及网络监视功能的企业级的开源解决方案。zabbix 能监视各种网络参数&#xff0c;保证服务器系统的安全运营&#xff1b;并提供灵活的通知机制以让系统管理员快速定位/解决存在的各种问题。 zabbix …

为什么需要消息中间件?

1.消息中间件是什么 消息队列&#xff08;MQ&#xff09;是一种系统间相互写作的通信机制&#xff0c;目前业界通常由两种方式来实现系统间通信&#xff0c;其中一种是基于远程过程调用的方式;另一种是基于消息队列的方式。前一种就是我们常说的RPC调用&#xff0c; 客户端不需…

leetcode—字母异位词

1 字母异位词分组 给你一个字符串数组&#xff0c;请你将 字母异位词 组合在一起。可以按任意顺序返回结果列表。 字母异位词 是由重新排列源单词的所有字母得到的一个新单词。 示例 1: 输入: strs ["eat", "tea", "tan", "ate",…

Linux 系统中常见的命令,它们用于执行各种任务,包括文件和目录管理、系统信息查看、用户管理等

以下是一些在 Linux 系统中常见的命令&#xff0c;它们用于执行各种任务&#xff0c;包括文件和目录管理、系统信息查看、用户管理等。这里列举了一些基础的命令&#xff1a; 文件和目录管理&#xff1a; ls: 列出目录内容。 ls cd: 切换当前目录。 cd /path/to/directory …

妹子回你消息冷淡了怎么办

她回信息慢&#xff0c;对你冷淡&#xff0c;怎么办? 你在微信上主动找她聊天&#xff0c;她回答你回得慢&#xff0c;慢慢的&#xff0c;你会觉得好像和她没戏了。然而&#xff0c;某一天她又突然主动找你聊天&#xff0c;对你又热情了一点&#xff0c;你觉得突然好像又有戏…

如何实现路由鉴权功能

什么是路由鉴权呢&#xff0c;分两个层面 1.如果我们还未登录的话&#xff0c;如果我们跳转其他路由&#xff0c;我们需要自动跳转到登陆页面&#xff0c;并且把跳转的目标路由通过query参数保留下来&#xff0c;点击登录之后&#xff0c;直接跳转过去即可 2.如果我们已经登录…