并发-大多程序都无法避免的,因为我们所做的大部分事情都需要并发,而且并发也是能否从多核的处理器中获得好的性能的一个条件。
一,同步访问共享的可变数据
同步并不是单单指线程之间的互斥。如果没有同步,一个线程的变化就不能被其他线程看到。同步不仅可以阻止一个线程看到对象处于不一致的状态之中,它还可以保证进入同步方法或者同步代码块的每个线程,都看到由同一个锁保护的之前的所以修改效果。
Java语言规范保证读或写一个变量是原子的(atomic)long和double除外。但是它并不保证一个线程写入的值对于另一个线程将是可见的(解释看下面的代码)。
import java.util.concurrent.TimeUnit; public class StopThread { private static boolean stopRequested; public static void main(String[] args) throws InterruptedException { Thread backgroundThread =new Thread(new Runnable(){ public void run() { int i=0; while(!stopRequested){ //不要使用Thread.stop因为它本质是不安全的(unsafe)使用它会导致数据遭到数据破坏 i++; } } }); backgroundThread.start(); TimeUnit.SECONDS.sleep(1); stopRequested=true; } }
你可能期待的这个程序大约运行一秒左右,之后主线程将stopRequested设置为true,从而导致后台线程终止。但是结果不是这样的!
问题在于,由于没有同步,就不能保证后台线程何时“看到”主线程对stopRequested的值所做的改变。没有同步,虚拟机这样处理这个代码:
while(!done){ i++; } /******转变为了********/ if(!done){ while(true); }
这种优化称作提升(hoisting)这是由于这种提升就导致了活性失败(liveness failure):这个程序无法前进。修正
import java.util.concurrent.TimeUnit; public class StopThread { private static boolean stopRequested; private static synchronized void requestStop(){ stopRequested=true; } private static synchronized boolean stopRequested(){ return stopRequested; } public static void main(String[] args) throws InterruptedException { Thread backgroundThread =new Thread(new Runnable(){ public void run() { int i=0; while(!stopRequested()){ //不要使用Thread.stop因为它本质是不安全的(unsafe)使用它会导致数据遭到数据破坏 i++; } } }); backgroundThread.start(); TimeUnit.SECONDS.sleep(1); //stopRequested=true; requestStop(); } }
写入方法(requestStop())和读取(stopRequest())方法作都被同步了。
StopThread中方法的同步是为了它的通信效果,而不是为了互斥访问。一种更加简洁,性能也可能更好的方法是将stopRequested声明为volatile。虽然volatile修饰符不执行互斥访问,但它可以保证任何一个线程在读取该field的时候都将看到最近刚刚被写入的值:
import java.util.concurrent.TimeUnit; public class StopThread { private static volatile boolean stopRequested; public static void main(String[] args) throws InterruptedException { Thread backgroundThread =new Thread(new Runnable(){ public void run() { int i=0; while(!stopRequested){ //不要使用Thread.stop因为它本质是不安全的(unsafe)使用它会导致数据遭到数据破坏 i++; } } }); backgroundThread.start(); TimeUnit.SECONDS.sleep(1); stopRequested=true; } }
二 避免使用过度同步
在一个被同步的区域内部,不要调用设计成要被覆盖的方法,或者是由客服端以函数对象的形式提供的方法。从包含该同步区域的类的角度来看这样的方法是外来的(alien)。这个类不知道该方法会做什么事情,也无法控制它,根据外来方法的作业,从同步区域调用它会导致异常,死锁或者数据的损坏。
以上内容全部来自《effective java》第二版 若想更深的而了解请参考原书
相关推荐
多线程并发编程-同步与互斥-原⼦变量-并发和⽆锁 数据结构
编译:来自CSAPP第7章链接94959697
模拟实现同步机构避免并发进程执行时可能出现的与时间有关的错误。 二. 实验目的 进程是程序在一个数据集合上运行的过程。进程是并发执行的,也即系统中的多个进程轮流的占用处理器运行。 我们把若干个进程都能进行...
springmvc+spring线程池处理http并发请求数据同步控制问题
实验目的: 1、 加深对进程概念的理解,区分进程并发执行与串行执行。 2、 掌握进程并发执行的原理,理解进程并发执行的特点。 3、 了解fork( )系统调用的返回值,...能利用相应的系统调用实现进程树与进程间的同步。
《java并发编程实战》读书笔记-第3章-对象的共享,脑图形式,使用xmind8制作 包括可见性、发布与逸出、线程封闭、不可变性、安全发布等内容
第三章 并发与同步:信号夏文副教授哈尔滨工业大学(深圳)2021年秋季信号的介绍 (Introduction to Signals)同步(Synchroniza
第三章 并发与同步:信号量夏文副教授哈尔滨工业大学(深圳)2021年秋季信号的介绍 (Introduction to Signals)同步(Synchroniz
SQL Server 2000完结篇系列之三:数据并发-彻底掌握SQL Server 2000事务机制
第3章 并发控制-互斥与同步 对于操作系统有系统的分析
在实际应用中,当众多GSMS客户线程各自并发地向GSMS数据中心同步数据时,所产生的大规模数据同步会话将汇聚在GSMS服务端,从而形成处理瓶颈。此外,同步会话全程串行的锁步机制也会制约大规模数据同步归集的性能。...
16.7.3 数据量大时JIMDB同步不动 342 16.7.4 切换主从 342 16.7.5 分片配置 342 16.7.6 模板元数据存储HTML 342 16.7.7 库存接口访问量600w/分钟 343 16.7.8 微信接口调用量暴增 344 16.7.9 开启Nginx Proxy Cache...
对飞机售票系统中的数据共享和并发访问的描述
Safe - Swift的现代并发和同步库
并发量-数据量-用户数-PV-服务器-优化
XP系统下共享连接数上限默认为10,局域网内访问XP的共享文件夹时经常提示“XP共享拒绝访问,已达到计算机连接的数量最大值”。若考虑用XP做文件服务器,只能修改TCP/IP并发数 XP共享连接数限制解除补丁,解决XP系统...
62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java...
模拟实现用同步机构避免发生进程执行时可能出现的与时间有关的错误。 二、实习目的 进程是程序在一个数据集合上运行的过程,进程是并发执行的,也即系统中的多个进程轮流地占用处理器运行。 我们把若干个进程都能...
go-bqstreamer - 快速和并发插入流数据至Google BigQuery
3. 基于Lock的并发数据结构 4. Condition Variables 条件变量 5. Semaphore 信号量 6. 常见并发问题 7. 基于事件的