---- 概述 在上篇博文并发编程-10线程安全策略之不可变对象 ,我们通过介绍使用线程安全的不可变对象可以保证线程安全。 除了上述方法,还有一种办法就是:线程封闭。 多个线程访问一个方法的时候,方法中的局部变量都会被拷贝一份到线程的栈中(Java内存模型),所以局部变量是不会被多个线程所共享的。 局部变量的固有属性之一就是封闭在线程中。 它们位于执行线程的栈中,其他线程无法访问这个栈。 ---- ThreadLocal 线程封闭 将可变数据通过每个线程有自己的独立副本从而实现线程封闭的机制 ThreadLocal类:线程本地变量。 局部变量,没啥好说的 ,直接看ThreadLocal实现线程安全吧 ---- ThreadLocal 假设我们将用户信息放到ThreadLocal中,然后从ThreadLocal中获取该用户信息。
一个进程的多个线程,共享同一份内存资源,如果两个线程,都尝试修改某个变量,就可能出现冲突; 某个逻辑单个线程执行是可以的,但是多个线程执行出现问题,这就是线程不安全,反之则线程安全 线程安全问题的原因 [ 根本原因 ] 操作系统对于线程的调度是随机的(没有办法应对) 两个线程针对同一个变量进行修改操作 修改操作不是原子的 内存可见性 指令重排序 eg:线程不安全例子 public class Demo14 5w次 ++ 操作,其结果应该为10w,但运行结果确像是一个<10w的随机值,这就是两个线程对同一变量修改的不安全。 count++操作实际是三次指令,将内存值加载到cpu寄存器中,在cpu寄存器中对值进行计算,将寄存器再写入到内存中,由于是三次指令,可能在某一条指令时调度到别的线程,这样的调度穿插过程就可能出现线程安全问题 虽然和synchronized都是解决线程安全问题,但和synchronized解决的是两种不同的问题。
线程安全是开发者在开发多线程任务时最关心的问题,那么线程安全需要注意哪些呢? 一、思考:线程安全产生的原因是什么? 二、final,volatile关键字的作用? 四、如何编写线程安全的程序? 五、ThreadLocal使用的注意事项有哪些? 一、思考:线程安全产生的原因是什么? 二、如何实现线程安全呢? 根据线程安全原因:可变资源(内存)线程间共享可得出: 不共享资源 共享不可变资源 共享可变资源(可见性、操作原子性、禁止重排序) 1、不共享资源 ThreadLocal: 如何使用ThreadLocal 提高程序的效率 synchronized (Singleton.class) { if (null == singleton) { //解决多线程下的安全性问题
在了解完这个问题后,我们又需要去了解一个使用多线程不得不考虑的问题——线程安全。今天我们不说如何保证一个线程的安全,我们聊聊什么是线程安全? 因为我之前面试被问到了,说真的,我之前真的不是特别了解这个问题,我们好像只学了如何确保一个线程安全,却不知道所谓的安全到底是什么!3、什么是线程安全? 那么由此我们可以了解到,这确实不是一个线程安全的类,因为他们都需要操作这个共享的变量。其实要对线程安全问题给出一个明确的定义,还是蛮复杂的,我们根据我们这个程序来总结下什么是线程安全。 搞清楚了什么是线程安全,接下来我们看看Java中确保线程安全最常用的两种方式。先来看段代码。 毫无疑问,它绝对是线程安全的,我们来分析一下,为什么它是线程安全的?
第二章 线程安全 2.1 线程安全 2.2 线程同步 2.3 同步代码块 2.4 同步方法 2.5 Lock锁 第三章 线程状态 3.1 线程状态概述 3.2 Timed Waiting(计时等待) 使用匿名内部类的方式实现 Runnable 接口,重新 Runnable 接口中的 run 方法: 第二章 线程安全 2.1 线程安全 如果有多个线程在同时运行,而这些线程可能会同时运行这段代码 我们通过一个案例,演示线程的安全问题: 电影院要卖票,我们模拟电影院的卖票过程。 这种问题,几个窗口 ( 线程 ) 票数不同步了,这种问题称为线程不安全。 线程安全问题都是由全局变量及静态变量引起的。 若每个线程中对全局变量、静态变量只有读操 作,而无写 操作,一般来说,这个全局变量是线程安全的;若有多个线程同时执行写操作,一般都需要考虑线 程同步, 否则的话就可能影响线程安全。
类型存储介质数据特征共享内存主内存存放变量多线程共享本地内存CPU 高速缓存、缓冲区、寄存器以及其它硬件优化临时存放线程使用的变量副本使用期间其它线程无法访问优势:由于 CPU 执行速度明先快于内存读写速度 可见性可见性是指当多个线程访问同一个变量时,一个线程修改了这个变量的值,其他线程能够立即看得到修改的值。Java 语言会尽可能保证主内存数据和本地内存同步,但仍可能出现不可见问题。 线程锁互斥锁和自旋锁互斥锁阻塞锁。当线程需要获取的锁已经被其他线程占用时,该线程会被直接挂起。直到其他线程释放锁,由操作系统激活线程。 适用于锁使用者保持锁时间比较长的情况,线程挂起后不再消耗 CPU 资源。自旋锁非阻塞锁。当线程需要获取的锁已经被其他线程占用时,该线程会不断地消耗 CPU 的时间去试图获取锁。 可重入锁允许一个线程对同一对象多次上锁。由 JVM 记录对象被线程加锁次数,只有当线程释放掉所有锁(加锁次数为0)时,其他线程才获准进入。
类型,也学习了多种线程同步的使用方法,这一篇主要讲述线程等待相关的内容。 在笔者认真探究多线程前,只会new Thread;锁?Lock;线程等待?Thread.Sleep()。 因为只有操作系统才能控制线程的生命周期,因此使用 Thread.Sleep() 等方式阻塞线程,发生上下文切换,此种等待称为内核模式。 用户模式使线程等待,并不需要线程切换上下文,而是让线程通过执行一些无意义的运算,实现等待。也称为自旋。 SpinWait 结构 微软文档定义:为基于自旋的等待提供支持。 自旋示例 下面来实现一个让当前线程等待其它线程完成任务的功能。 其功能是开辟一个线程对 sum 进行 +1,当新的线程完成运算后,主线程才能继续运行。
AQS 核心思想是通过以下方式,建立一套线程阻塞等待以及被唤醒时锁分配的机制。如果被请求的共享资源空闲,则将当前请求资源的线程设置为有效的工作线程,并且将共享资源设置为锁定状态。 如果被请求的共享资源被占用,就将暂时获取不到锁的线程封装成一个结点,加入到一个虚拟的双向队列 CLH 中。CLH 不存在真实的队列,仅存在结点之间的关联关系。 线程抢占资源时会通过 CAS 操作去尝试修改 state ,成功则获取锁成功,失败则进入等待队列等待被唤醒。 Share(共享)多个线程可同时执行,如 Semaphore/CountDownLatch。 isHeldExclusively():该线程是否正在独占资源。只有用到condition才需要去实现它。 tryAcquire(int):独占方式。
线程没有自己的系统资源 3.线程与进程的区别 线程是执行的指令集 , 进程是资源的集合 线程的启动速度要比进程的启动速度要快 两个线程的执行速度是一样的 进程与线程的运行速度是没有可比性的 线程共享创建它的进程的内存空间 如果两个进程之间需要通信 , 就必须要通过一个中间代理来实现 一个新的线程很容易被创建 , 一个新的进程创建需要对父进程进行一次克隆 一个线程可以控制和操作同一个进程里的其他线程 , 线程与线程之间没有隶属关系 ) t2.start() print('I am main thread') #主线程 #这个进程里面有三个线程,1个主线程,t1,t2两个子线程 #子线程和主线程是同步开启的 与此同时一个线程也立刻运行 , 该线程通常叫做程序的主线程 子线程 : 因为程序是开始时就执行的 , 如果你需要再创建线程 , 那么创建的线程就是这个主线程的子线程 join的作用:是保证当前线程执行完成后 (互斥锁Mutex) lock:如果有多个进程对同一文件进行修改 , 就会造成错乱 , 所以我们为了保护文件数据的安全 , 就需要给其进行加锁,join为整体串行 , lock为局部串行 Rlock:在线程间共享多个资源的时候
一、什么是线程安全? 二、java语言中的线程安全 我们将java语言中各种操作共享的数据分为以下5类:不可变、绝对线程安全、相对线程安全、线程兼容和线程对立。 绝对线程安全 在Java API中标注自己是线程安全的类,大多数都不是绝对的线程安全。我们可以通过Java API中一个不是“绝对线程安全”的线程安全类来看看这里的“绝对”是什么意思。 相对线程安全 相对的线程安全就是我们通常意义上所讲的线程安全,它需要保证对这个对象单独的操作是线程安全的,我们在调用的时候不需要做额外的保障措施,但是对于一些特定顺序的连续调用,就可能需要在调用端使用额外的同步手段来保证调用的正确性 线程兼容 线程兼容是指对象本身不是线程安全的,但是可以通过在调用端正确地使用同步手段来保证对象在并发环境中可以安全地使用。
线程安全: 线程安全就是多线程访问时,采用了加锁机制,当一个线程访问该类的某个数据时,进行保护,其他线程不能进行访问直到该线程读取完,其他线程才可使用。不会出现数据不一致或者数据污染。 线程不安全就是不提供数据访问保护,有可能出现多个线程先后更改数据造成所得到的数据是脏数据。 如何保证呢: 1、使用线程安全的类; 2、使用synchronized同步代码块,或者用Lock锁; > 由于线程安全问题,使用synchronized同步代码块 原理:当两个并发线程访问同一个对象 object中的这个synchronized(this)同步代码块时,一个时间内只能有一个线程得到执行。 另一个线程必须等待当前线程执行完这个代码块以后才能执行该代码块。 3、多线程并发情况下,线程共享的变量改为方法局部级变量; 参考学习:线程安全和线程同步Synchronized
移动端开发过程中,会出现 进程 和 线程的概念,以及多线程中 线程安全 的问题。 ThreadPoolExecutor.DiscardOldestPolicy()); private ExecutorService grayThreadPool = Executors.newSingleThreadExecutor(); 线程安全 所以在多个线程同时访问数据时,也就会引入线程安全的问题。 多线程安全要解决的问题是,不同线程访问同一数据时的数据安全问题。 解决线程安全的常用方法是增加 synchronized 关键字. synchronized使用示例: //synchronized 加在方法上 private synchronized void setNewValue 线程数据同步安全中,volatile关键字也是比较常用的, volatile关键字能够保证可见性,被volatile修饰的变量,在一个线程中被改变时会立刻同步到主内存中,而另一个线程在操作这个变量时都会先从主内存更新这个变量的值
5 变量的线程安全分析 成员变量和静态变量是否线程安全? 如果它们没有共享,则线程安全 如果它们被共享了,根据它们的状态是否能够改变,又分两种情况 如果只有读操作,则线程安全 如果有读写操作,则这段代码是临界区,需要考虑线程安全 局部变量是否线程安全? 局部变量是线程安全的 但局部变量引用的对象则未必 如果该对象没有逃离方法的作用访问,它是线程安全的 如果该对象逃离方法的作用范围,需要考虑线程安全 1 成员变量 先看一个成员变量的例子 class 给个提示,这些线程安全类的方法,单个是线程安全的,那么多个组合起立还是不是呢。 所以不存在线程安全。
这些面试题常被问,答案是,左边的都是非线程安全,右边都是线程安全! 然后又问你,什么是线程安全,什么是非线程安全呢? A.线程安全 当多个线程类并发操作某类的方法A,来修改这个A方法的某个成员变量的值B,B不会出错,则我们就说,该的这个A方法是线程安全的。 B.非线程安全 当多个线程类并发操作某类的方法A,来修改这个A方法的某个成员变量的值B,B会出错,则我们就说,该的这个A方法是非线程安全的。 线程执行dou()方法的时候,实例pi返回的是当前线程的对象。这样的调用是线程安全的。 线程安全跟非线程安全如何取舍 从第一个例子可得知,非线程的方法添加synchronized修饰就可以转化为线程安全,但是性能会相差20倍左右,如果不加的话,该类的成员变量又可能发生错误,所以具体就看你的需求
线程安全 线程是越多越好吗?答案否,线程太多的话,会造成CPU频繁的切换反而会造成很多线程处于等待状态。 除了浪费资源和效率之外,多线程带来的其他风险:安全、死锁等 比如下面程序: public class CountAdd implements Callable { private Map<String 这时就会出现多个线程值被覆盖的情况,比如,线程1 第一次count = 0;在进行+1操作之前,线程2已经完成了+1操作并将值赋给了count,这时count应该是1。而线程1中的count还是0。 map.getOrDefault("count", 0); map.put("count", ++integer); } 为什么加synchronized就可以让线程变的安全 synchronized是一种锁,JUC的Lock是一种锁,锁是在多线程中为了保障程序的安全性的一种同步机制。 多线程+锁=万无一失?多度的使用锁,锁的创建和销毁相应的开销越大。
在多线程中使用共享资源,对共享资源的操作不是原子性,就会导致数据不一致的情况 例如 : index ++ 操作 index ++ 实际上相当于 1. index + 1 2. 将结果赋值 index 数据漏过 主要是由于线程1修改后index值已改变未输出前,cpu将权利交给线程2,线程2继续累加并输出 2.数据重复 主要是由于线程1执行到index +1但是还没赋值index ,cpu就将执行权交给线程2 3.超过最大值 当index=499 时线程1和线程2都看到满足条件,线程1将index增加到500后,线程2恢复执行变为501 synchronized synchronized 如果monitor的计数器为0,则意味着monitor的lock还没有被获得,某个线程获得之后计数器加1 如果一个monitor的所有权的线程重入,则会导致moniter的计数器再次累加 如果monitor 已经被其他线程所拥有,则其他线程再尝试获取所有权时,被陷入阻塞状态,直到monitor计数器变为0,才能再次获取 Monitor exit 释放monitor所有权就是将计数器减一,前提是必须拥有所有权
欢迎关注微信公众号:数据科学与艺术 作者WX:superhe199 线程安全指的是在多线程环境下,共享的资源能够被正确地访问和操作,不会出现数据不一致或者异常的情况。 原子操作能够保证不可分割地执行,从而避免了线程切换的时候出现的数据不一致问题。 使用线程安全的数据结构,如线程安全的队列、集合等。 这些数据结构在设计时考虑了多线程操作的问题,能够保证在多线程环境下的安全性。 使用线程局部存储(Thread Local Storage,TLS)来存储线程私有的数据,避免共享资源的竞争。 count变量的递增操作是线程安全的。 最终输出的结果应该是10000,如果没有线程安全措施,可能会出现不确定的结果。
什么是线程池 线程池: 提供了一个线程队列,队列中保存着所有等待状态的线程。避免了创建与销毁额外开销,提高了响应的速度。 第四种获取线程的方法:线程池,一个 ExecutorService,它使用可能的几个池线程之一执行每个提交的任务,通常使用 Executors 工厂方法配置。 线程池的体系结构: java.util.concurrent.Executor:负责线程的使用与调度的根接口 ExecutorService 子接口:线程池的主要接口 ThreadPoolExecutor ():创建单个线程池,线程池中只有一个线程 ScheduledExecutorService newSchedualedThreadPool():创建固定大小的线程,可以延迟或定时的执行任务 举个例子 相对于一般的线程池实现,fork/join框架的优势体现在对其中包含的任务的处理方式上.在一般的线程池中,如果一个线程正在执行的任务由于某些原因无法继续运行,那么该线程会处于等待状态。
回归正题,当我们查看JDK API的时候,总会发现一些类说明写着,线程安全或者线程不安全,比如说StringBuilder中,有这么一句,“将StringBuilder 的实例用于多个线程是不安全的。 ”,那么下面手动创建一个线程不安全的类,然后在多线程中使用这个类,看看有什么效果。 每次启动一个线程使用不同的线程类,不推荐。 上述测试,我们发现,存在成员变量的类用于多线程时是不安全的,不安全体现在这个成员变量可能发生非原子性的操作,而变量定义在方法内也就是局部变量是线程安全的。 想想在使用struts1时,不推荐创建成员变量,因为action是单例的,如果创建了成员变量,就会存在线程不安全的隐患,而struts2是每一次请求都会创建一个action,就不用考虑线程安全的问题。
锁 C++11中锁的使用规则 与 Linux的锁基本一致,所以例如 lock /unlock 等接口说明不是很详细 点击查看:Linux中的锁 1. 为什么要使用锁? 和线程B,只有当线程A跑完后, 线程B才能再跑 ---- C++11中使用lambda表达式 也可替换函数指针的位置,内部通过函数体 来实现 x++ 在进行for循环之前使用 lock 加锁,在循环结束 ,导致栈溢出了 ---- 若存在线程安全问题,则需要加锁 线程v1 先加锁,还没等解锁,递归再次调用func函数 进行加锁 ,导致死锁问题 ,使程序挂掉了 (死锁: 两个线程各自持有自己的锁,并向对方申请锁 点,若到11点还没解锁就自动解锁 lock_guard 与 unique_lock 先进入try 进行加锁,由于抛异常 ,进入catch ,跳过了解锁操作 ,再次循环进入try 对其进行加锁,存在 条件变量 在C++11中条件变量 的使用 与 linux中的条件变量 差不多 点击查看:Linux下的条件变量 线程等待 ---- C++11推荐把锁对象 给 unique_lock 对线程进行阻塞