聊聊保证线程安全的10个小技巧
``
前言
对于从事后端开发的同学来说,线程安全
问题是我们每天都需要考虑的问题。
线程安全问题通俗的讲:主要是在多线程的环境下,不同线程同时读和写公共资源(临界资源),导致的数据异常问题。
比如:变量a=0,线程1给该变量+1,线程2也给该变量+1。此时,线程3获取a的值有可能不是2,而是1。线程3这不就获取了错误的数据?
线程安全问题会直接导致数据异常,从而影响业务功能的正常使用,所以这个问题还是非常严重的。
那么,如何解决线程安全问题呢?
今天跟大家一起聊聊,保证线程安全的10个小技巧,希望对你有所帮助。
1. 无状态
我们都知道只有多个线程访问公共资源
的时候,才可能出现数据安全问题,那么如果我们没有公共资源,是不是就没有这个问题呢?
例如:
public class NoStatusService {public void add(String status) {System.out.println("add status:" + status);}public void update(String status) {System.out.println("update status:" + status);}
}
这个例子中NoStatusService没有定义公共资源,换句话说是无状态
的。
这种场景中,NoStatusService类肯定是线程安全的。
2. 不可变
如果多个线程访问的公共资源是不可变
的,也不会出现数据的安全性问题。
例如:
public class NoChangeService {public static final String DEFAULT_NAME = "abc";public void add(String status) {System.out.println(DEFAULT_NAME);}
}
DEFAULT_NAME被定义成了static
final
的常量,在多线程中环境中不会被修改,所以这种情况,也不会出现线程安全问题。
3. 无修改权限
有时候,我们定义了公共资源,但是该资源只暴露了读取的权限,没有暴露修改的权限,这样也是线程安全的。
例如:
public class SafePublishService {private String name;public String getName() {return name;}public void add(String status) {System.out.println("add status:" + status);}
}
这个例子中,没有对外暴露修改name字段的入口,所以不存在线程安全问题。
3. synchronized
使用JDK
内部提供的同步机制
,这也是使用比较多的手段,分为:同步方法
和 同步代码块
。
我们优先使用同步代码块,因为同步方法的粒度是整个方法,范围太大,相对来说,更消耗代码的性能。
其实,每个对象内部都有一把锁
,只有抢到那把锁的线程
,才被允许进入对应的代码块执行相应的代码。
当代码块执行完之后,JVM底层会自动释放那把锁。
例如:
public class SyncService {private int age = 1;private Object object = new Object();//同步方法public synchronized void add(int i) {age = age + i; System.out.println("age:" + age);}public void update(int i) {//同步代码块,对象锁synchronized (object) {age = age + i; System.out.println("age:" + age);} }public void update(int i) {//同步代码块,类锁synchronized (SyncService.class) {age = age + i; System.out.println("age:" + age);} }
}
4. Lock
除了使用synchronized
关键字实现同步功能之外,JDK还提供了Lock
接口,这种显示锁的方式。
通常我们会使用Lock
接口的实现类:ReentrantLock
,它包含了:公平锁
、非公平锁
、可重入锁
、读写锁
等更多更强大的功能。
例如:
public class LockService {private ReentrantLock reentrantLock = new ReentrantLock();public int age = 1;public void add(int i) {try {reentrantLock.lock();age = age + i; System.out.println("age:" + age);} finally {reentrantLock.unlock(); } }
}
但如果使用ReentrantLock,它也带来了有个小问题就是:需要在finally代码块中手动释放锁
。
不过说句实话,在使用Lock
显示锁的方式,解决线程安全问题,给开发人员提供了更多的灵活性。
5. 分布式锁
如果是在单机的情况下,使用synchronized
和Lock
保证线程安全是没有问题的。
但如果在分布式的环境中,即某个应用如果部署了多个节点,每一个节点使用可以synchronized
和Lock
保证线程安全,但不同的节点之间,没法保证线程安全。
这就需要使用:分布式锁
了。
分布式锁有很多种,比如:数据库分布式锁,zookeeper分布式锁,redis分布式锁等。
其中我个人更推荐使用redis分布式锁,其效率相对来说更高一些。
使用redis分布式锁的伪代码如下:
try{String result = jedis.set(lockKey, requestId, "NX", "PX", expireTime);if ("OK".equals(result)) {return true;}return false;
} finally {unlock(lockKey);
}
同样需要在finally
代码块中释放锁。
如果你对redis分布式锁的用法和常见的坑,比较感兴趣的话,可以看看我的另一篇文章《聊聊redis分布式锁的8大坑》,里面有更详细的介绍。
6. volatile
有时候,我们有这样的需求:如果在多个线程中,有任意一个线程,把某个开关的状态设置为false,则整个功能停止。
简单的需求分析之后发现:只要求多个线程间的可见性
,不要求原子性
。
如果一个线程修改了状态,其他的所有线程都能获取到最新的状态值。
这样一分析这就好办了,使用volatile
就能快速满足需求。
例如:
@Service
public CanalService {private volatile boolean running = false;private Thread thread;@Autowiredprivate CanalConnector canalConnector;public void handle() {//连接canalwhile(running) {//业务处理}}public void start() {thread = new Thread(this::handle, "name");running = true;thread.start();}public void stop() {if(!running) {return;}running = false;}
}
需要特别注意的地方是:
volatile
不能用于计数和统计等业务场景。因为volatile
不能保证操作的原子性,可能会导致数据异常。
7. ThreadLocal
除了上面几种解决思路之外,JDK还提供了另外一种用空间换时间
的新思路:ThreadLocal
。
当然ThreadLocal并不能完全取代锁,特别是在一些秒杀更新库存中,必须使用锁。
ThreadLocal的核心思想是:共享变量在每个线程都有一个副本,每个线程操作的都是自己的副本
,对另外的线程没有影响。
温馨提醒一下:我们平常在使用ThreadLocal时,如果使用完之后,一定要记得在
finally
代码块中,调用它的remove
方法清空数据,不然可能会出现内存泄露
问题。
例如:
public class ThreadLocalService {private ThreadLocal<Integer> threadLocal = new ThreadLocal<>();public void add(int i) {Integer integer = threadLocal.get();threadLocal.set(integer == null ? 0 : integer + i);}
}
如果对ThreadLocal感兴趣的小伙伴,可以看看我的另一篇文章《ThreadLocal夺命11连问》,里面有对ThreadLocal的原理、用法和坑,有非常详细的介绍。
8. 线程安全集合
有时候,我们需要使用的公共资源放在某个集合当中,比如:ArrayList、HashMap、HashSet等。
如果在多线程环境中,有线程往这些集合中写数据,另外的线程从集合中读数据,就可能会出现线程安全问题。
为了解决集合的线程安全问题,JDK专门给我们提供了能够保证线程安全的集合。
比如:CopyOnWriteArrayList、ConcurrentHashMap、CopyOnWriteArraySet、ArrayBlockingQueue等等。
例如:
public class HashMapTest {private static ConcurrentHashMap<String, Object> hashMap = new ConcurrentHashMap<>();public static void main(String[] args) {new Thread(new Runnable() {@Overridepublic void run() {hashMap.put("key1", "value1");}}).start();new Thread(new Runnable() {@Overridepublic void run() {hashMap.put("key2", "value2");}}).start();try {Thread.sleep(50);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(hashMap);}
}
在JDK底层,或者spring框架当中,使用ConcurrentHashMap保存加载配置参数的场景非常多。
比较出名的是spring的refresh
方法中,会读取配置文件,把配置放到很多的ConcurrentHashMap缓存起来。
9. CAS
JDK除了使用锁的机制解决多线程情况下数据安全问题之外,还提供了CAS机制
。
这种机制是使用CPU中比较和交换指令的原子性,JDK里面是通过Unsafe
类实现的。
CAS内部包含了四个值:旧数据
、期望数据
、新数据
和 地址
,比较旧数据 和 期望的数据,如果一样的话,就把旧数据改成新数据。如果不一样的话,当前线程不断自旋
,一直到成功为止。
不过,使用CAS保证线程安全,可能会出现ABA
问题,需要使用AtomicStampedReference
增加版本号解决。
其实,实际工作中很少直接使用Unsafe
类的,一般用atomic
包下面的类即可。
public class AtomicService {private AtomicInteger atomicInteger = new AtomicInteger();public int add(int i) {return atomicInteger.getAndAdd(i);}
}
10. 数据隔离
有时候,我们在操作集合数据时,可以通过数据隔离
,来保证线程安全。
例如:
public class ThreadPoolTest {public static void main(String[] args) {ExecutorService threadPool = new ThreadPoolExecutor(8, //corePoolSize线程池中核心线程数10, //maximumPoolSize 线程池中最大线程数60, //线程池中线程的最大空闲时间,超过这个时间空闲线程将被回收TimeUnit.SECONDS,//时间单位new ArrayBlockingQueue(500), //队列new ThreadPoolExecutor.CallerRunsPolicy()); //拒绝策略List<User> userList = Lists.newArrayList(new User(1L, "苏三", 18, "成都"),new User(2L, "苏三说技术", 20, "四川"),new User(3L, "技术", 25, "云南"));for (User user : userList) {threadPool.submit(new Work(user));}try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(userList);}static class Work implements Runnable {private User user;public Work(User user) {this.user = user;}@Overridepublic void run() {user.setName(user.getName() + "测试");}}
}
这个例子中,使用线程池
处理用户信息。
每个用户只被线程池
中的一个线程
处理,不存在多个线程同时处理一个用户的情况。所以这种人为的数据隔离机制,也能保证线程安全。
数据隔离还有另外一种场景:kafka生产者把同一个订单的消息,发送到同一个partion中。每一个partion都部署一个消费者,在kafka消费者中,使用单线程接收消息,并且做业务处理。
这种场景下,从整体上看,不同的partion是用多线程处理数据的,但同一个partion则是用单线程处理的,所以也能解决线程安全问题。
如果你对kafka的使用比较感兴趣,可以看看我的另一篇干货文章《我用kafka两年踩过的一些非比寻常的坑》。
聊聊保证线程安全的10个小技巧相关推荐
- 你一定要知道的保证线程安全的10个小技巧
导语 对于从事后端开发的同学来说,线程安全问题是我们每天都需要考虑的问题. 线程安全问题通俗的讲:主要是在多线程的环境下,不同线程同时读和写公共资源(临界资源),导致的数据异常问题. 比如:变量a=0 ...
- 后端开发—10个小技巧教你保证线程安全
前言 对于从事后端开发的同学来说,线程安全问题是我们每天都需要考虑的问题. 线程安全问题通俗的讲:主要是在多线程的环境下,不同线程同时读和写公共资源(临界资源),导致的数据异常问题. 比如:变量a=0 ...
- ☆ 10个小技巧,让你的 Python 代码更加优雅~ ☆
10个小技巧改进的 Python 代码,让你的代码更加简洁.更加 Python 化. 1. 用enumerate代替range 如果你需要遍历一个列表,并且需要同时获取索引和元素,大多数情况可能会使用 ...
- omnigraffle 画曲线_OmniGraffle使用的10个小技巧
OmniGraffle是由The Omni Group制作的一款绘图软件,其只能于运行在Mac OS X和iPad平台之上.在很多方面,OmniGraffle都类似于Microsoft Visio.下 ...
- Word2003的10个小技巧(转)
Word2003的10个小技巧(转) word2003是现在比较流行的文字处理软件之一,也是Office2003办公套装软件的一个重要组成部分.以下是word2003的十个实用小技巧,希望大家在今后使 ...
- omnigraffle 导出html,OmniGraffle使用的10个小技巧
原文发表于http://www.weste.net/2014/3-7/95727.html OmniGraffle是由The Omni Group制作的一款绘图软件,其只能于运行在Mac OS X和i ...
- Mac入门必须要知道的10个小技巧
刚开始不了解Mac时,会觉得很麻烦,但是学习一串小技巧后,你会发现mac系统很有用.以下是一些比较基础的Mac小技巧,希望会帮到更入手mac的小伙伴们. 1.快速找到光标 如果在混乱之中找不到屏幕中的 ...
- 聊聊接口性能优化的11个小技巧
点击下方"IT牧场",选择"设为星标" 前言 接口性能优化对于从事后端开发的同学来说,肯定再熟悉不过了,因为它是一个跟开发语言无关的公共问题. 该问题说简单也简 ...
- 详细的聊聊接口性能优化的11个小技巧 不收藏对不起我
前言 接口性能优化对于从事后端开发的同学来说,肯定再熟悉不过了,因为它是一个跟开发语言无关的公共问题. 该问题说简单也简单,说复杂也复杂. 有时候,只需加个索引就能解决问题. 有时候,需要做代码重构. ...
最新文章
- php用户鉴权,app开发之鉴权 PHP版
- 总结jenkins Android自动打包遇到的坑
- python学习笔记-5.18
- unittest单元测试框架—加载测试用例的3种方法以及测试报告存储管理
- python爬虫从入门到放弃(一)之初识爬虫
- Android开发之WebView加载HTML源码包含转义字符实现富文本显示的方法
- 思科智能交换机受多个严重漏洞影响
- 视频图像处理基础知识0(双线性插值算法进行图像缩放)【转】
- 不同tric 改进的理由
- 最新毕业设计参考文献大全
- 什么是二进制,进制之间是如何转换的,浅显易懂的,一看就会
- eclipse 安装jetty WTP Adaptor插件
- v.douyin.com/xxx抖音网址官方生成制作抖音缩短口令网址php接口方法
- Kaggle数据集之电信客户流失数据分析(三)之决策树分类
- “C++”读作「C 加加」,为什么“C♯”不能读作「C 井」呢?
- BatchNorm、LayerNorm、InstanceNorm、GroupNorm、WeightNorm
- PTA1025C语言解析
- 中国制造2025主攻方向是智能制造
- 【数据库考试】数据库系统概论
- 同构和异构经典图神经网络汇总+pytorch代码
热门文章
- 天锋w2019_天锋W2019竟然仿的这么像,这是要让三星气吐血吗?
- git恢复commit过的代码
- onion spring_英语里的葱不都是Onion
- ASP.NET正则实现表情替换为图片,如[hanx]替换为img src=img/hanx.gif/
- 时域和频域的简单理解
- 超分辨率(CVPR2020) ~《Video Super-resolution with Temporal Group Attention》
- 计算机专业排名211大学排名,计算机专业大学排名,计算机专业强的211!
- 统计单表中时间有重叠的数据--同一人出入院时间重叠
- php语言的应用领域,探讨主要的PHP应用领域
- 老贾笔记--轻轻松松oracle之logmnr篇[吃顿饭的功夫学恢复误删除(delete)的数据]