Cet article vous apporte des connaissances pertinentes sur java, qui présente principalement les problèmes liés au multi-threading, notamment l'installation de threads, le verrouillage des threads et l'insécurité des threads, les classes thread-safe standard, etc. Contenu, j'espère qu'il sera utile à tout le monde .
Étude recommandée : "Tutoriel vidéo Java"
Cet article présente les problèmes de sécurité des threads dans le multithreading Java. Les problèmes de sécurité ici ne font pas référence aux problèmes de sécurité causés par les pirates. Les problèmes de sécurité des threads font référence à des bogues. programmes causés par une exécution préemptive multithread.
1. Présentation de la sécurité des threads
1.1 Qu'est-ce qu'un problème de sécurité des threads
Tout d'abord, nous devons comprendre que la planification des threads dans le système d'exploitation est préemptive ou aléatoire, ce qui entraîne l'ordre d'exécution des threads lors de la planification des threads. est exécuté. Il est incertain. L'ordre d'exécution de certains codes n'affecte pas les résultats d'exécution du programme, mais certains codes modifient l'ordre d'exécution et les résultats d'exécution réécrits seront affectés. Pour la concurrence multithread, le code qui provoque des bogues dans un programme est appelé code non sécurisé. Il s'agit d'un problème de sécurité des threads.
Ci-dessous, nous présenterons un exemple typique de problème de sécurité des threads, le problème d'auto-incrémentation d'entiers.
1.2 Un programme avec des problèmes de sécurité des threads
Un jour, l'enseignant a assigné un tel problème : utiliser deux threads pour incrémenter la variable count de 10 fois, à chaque fois. le thread entreprend la tâche d'auto-incrémentation 5 fois, et la valeur initiale de la variable count est 0.
Cette question est très simple. Nous pouvons également calculer le résultat final verbalement. La réponse est 100 millions.
Xiao Ming a travaillé très vite et a rapidement écrit le morceau de code suivant : count自增10万次，每个线程承担5万次的自增任务，变量count的初始值为0。
这个问题很简单，最终的结果我们也能够口算出来，答案就是10万。
小明同学做事非常迅速，很快就写出了下面的一段代码：
class Counter {
private int count;
public void increase() {
++this.count;
}
public int getCount() {
return this.count;
}}public class Main11 {
private static final int CNT = 50000;
private static final Counter counter = new Counter();
public static void main(String[] args) throws InterruptedException {
Thread thread1 = new Thread(() -> {
for (int i = 0; i {
for (int j = 0; j <p>按理来说，结果应该是<code>10</code>万，我们来看看Parlons des problèmes de sécurité des threads du multithreading Java：<br><img src="https://img.php.cn/upload/article/000/000/067/5a3746e6458021f78f91292b5a885487-1.png" alt="Parlons des problèmes de sécurité des threads du multithreading Java"><br> 运行的结果比<code>10</code>万要小，你可以试着运行该程序你会发现每次运行的结果都不一样，但绝大部分情况，结果都会比预期的值要小，下面我们就来分析分析为什么会这样。</p><h2><strong>2.线程Parlons des problèmes de sécurité des threads du multithreading Java与线程不安全的原因</strong></h2><h2>2.1案例分析</h2><p>上面我们使用多线程运行了一个程序，将一个变量值为0的变量自增10万次，但是最终实际结果比我们预期结果要小，原因就是线程调度的顺序是随机的，造成线程间自增的指令集交叉，导致运行时出现两次自增但值只自增一次的情况，所以得到的结果会偏小。</p><p>我们知道一次自增操作可以包含以下几条指令：</p><ol>
<li>将内存中变量的值加载到寄存器，不妨将该操作记为<code>load</code>。</li>
<li>在寄存器中执行自增操作，不妨将该操作记为<code>add</code>。</li>
<li>将寄存器的值保存至内存中，不妨将该操作记为<code>save</code>。</li>
</ol><p>我们来画一条时间轴，来总结一下常见的几种情况：</p><p><strong>Parlons des problèmes de sécurité des threads du multithreading Java：</strong> 线程间指令集，无交叉，Parlons des problèmes de sécurité des threads du multithreading Java与预期相同，图中寄存器A表示线程1所用的寄存器，寄存器B表示线程2所用的寄存器，后续情况同理。<br><img src="https://img.php.cn/upload/article/000/000/067/1a7f0bb1b7c2552a80983e04b900dc15-2.png" alt="Parlons des problèmes de sécurité des threads du multithreading Java"><br><strong>Parlons des problèmes de sécurité des threads du multithreading Java：</strong> 线程间指令集存在交叉，Parlons des problèmes de sécurité des threads du multithreading Java低于预期结果。<br><img src="https://img.php.cn/upload/article/000/000/067/1a7f0bb1b7c2552a80983e04b900dc15-3.png" alt="Parlons des problèmes de sécurité des threads du multithreading Java"><br><strong>Parlons des problèmes de sécurité des threads du multithreading Java：</strong> 线程间指令集完全交叉，实际结果低于预期。<br><img src="https://img.php.cn/upload/article/000/000/067/4e482e48ea6191128516ca82417af3cf-4.png" alt="Parlons des problèmes de sécurité des threads du multithreading Java"><br> 根据上面我们所列举的情况，发现线程运行时没有交叉指令的时候Parlons des problèmes de sécurité des threads du multithreading Java是正常的，但是一旦有了交叉会导致自增操作的结果会少<code>1</code></p><div class="code" style="position:relative; padding:0px; margin:0px;"><pre class="brush:php;toolbar:false">class Counter {
private int count;
synchronized public void increase() {
++this.count;
}
public int getCount() {
return this.count;
}}Copier après la connexion
Copier après la connexion
Logiquement parlant, le résultat devrait être de
10 millions. Jetons un coup d'œil aux résultats en cours :
Exécution du le résultat est inférieur à
10. Vous pouvez essayer d'exécuter le programme et vous constaterez que les résultats sont différents à chaque fois. Mais dans la plupart des cas, les résultats seront inférieurs à la valeur attendue. analyser pourquoi c'est le cas.
2. Raisons du verrouillage des threads et de l'insécurité des threads
2.1 Analyse de cas
Ci-dessus, nous avons utilisé le multithreading pour exécuter un programme et incrémenter une variable d'une valeur de 0 à 100 000 fois, mais le résultat final réel Le résultat est plus petit que ce à quoi nous nous attendions. La raison en est que l'ordre de planification des threads est aléatoire, ce qui provoque le chevauchement des jeux d'instructions d'auto-incrémentation des threads, ce qui entraîne deux auto-incréments pendant l'exécution mais un seul auto-incrémentation, donc les résultats obtenus seront être partial.
Nous savons qu'une opération d'incrémentation peut inclure les instructions suivantes : 🎜
- Charger la valeur de la variable en mémoire dans le registre. Vous souhaiterez peut-être enregistrer cette opération sous le nom
load. .
- Pour effectuer une opération d'auto-incrémentation dans un registre, vous souhaiterez peut-être enregistrer l'opération sous la forme
add.
- Enregistrer la valeur du registre en mémoire. Vous souhaiterez peut-être enregistrer cette opération sous
save.
🎜Traçons une chronologie pour résumer plusieurs situations courantes : 🎜🎜🎜Cas 1 : 🎜 Jeu d'instructions inter-thread, pas de croisement, les résultats de fonctionnement sont les mêmes que prévu, registre A dans l'image Indique le registre utilisé par le thread 1, et le registre B indique le registre utilisé par le thread 2. Il en va de même pour les situations ultérieures.
🎜Cas 2 :🎜 Il y a un chevauchement dans les jeux d'instructions entre les threads et les résultats en cours d'exécution sont inférieurs aux attentes.
🎜Cas 3 :🎜 Les jeux d'instructions sont complètement croisés entre les threads et les résultats réels sont inférieurs aux attentes.
Selon le ci-dessus, nous Dans les situations répertoriées, on constate que les résultats d'exécution sont normaux lorsqu'il n'y a pas d'instruction croisée lorsque le thread est en cours d'exécution, mais une fois qu'il y a une croix, le résultat de l'opération d'auto-incrémentation sera inférieur à
1 . Pour résumer, une conclusion peut être tirée : c'est parce que l'opération d'auto-incrémentation n'est pas atomique et que l'exécution simultanée de plusieurs threads est susceptible de provoquer un chevauchement de l'exécution des instructions, entraînant des problèmes de sécurité des threads. 🎜🎜Alors, comment résoudre le problème de sécurité du fil de discussion ci-dessus ? Bien sûr, il y en a, c'est pour verrouiller l'objet. 🎜🎜2.2 Verrouillage des threads🎜🎜🎜2.2.1 Qu'est-ce que le verrouillage🎜🎜🎜Afin de résoudre le problème de sécurité des threads causé par "l'exécution préemptive", nous pouvons verrouiller l'objet de l'opération lorsqu'un thread obtient le verrouillage de l'objet. , l'objet sera verrouillé. Si d'autres threads doivent effectuer la tâche de l'objet, ils doivent attendre que le thread ait fini d'exécuter la tâche de l'objet avant de pouvoir l'exécuter. 🎜
举个例子，假设要你去银行的ATM机存钱或者取款，每台ATM机一般都在一间单独的小房子里面，这个小房子有一扇门一把锁，你进去使用ATM机时，门会自动的锁上，这个时候如果有人要来取款，那它得等你使用完并出来它才能进去使用ATM，那么这里的“你”相当于线程，ATM相当于一个对象，小房子相当于一把锁，其他的人相当于其他的线程。
在java中最常用的Parlons des problèmes de sécurité des threads du multithreading Java操作就是使用synchronized关键字进行Parlons des problèmes de sécurité des threads du multithreading Java。
2.2.2如何Parlons des problèmes de sécurité des threads du multithreading Java
synchronized 会起到互斥效果, 某个线程执行到某个对象的 synchronized 中时, 其他线程如果也执行到同一个对象 synchronized 就会阻塞等待。
线程进入 synchronized 修饰的代码块, 相当于Parlons des problèmes de sécurité des threads du multithreading Java，退出 synchronized 修饰的代码块, 相当于 解锁。
java中的Parlons des problèmes de sécurité des threads du multithreading Java操作可以使用synchronized关键字来实现，它的常见使用方式如下：
方式1： 使用synchronized关键字修饰普通方法，这样会使方法所在的对象加上一把锁。
例如，就以上面自增的程序为例，尝试使用synchronized关键字进行Parlons des problèmes de sécurité des threads du multithreading Java，如下我对increase方法进行了Parlons des problèmes de sécurité des threads du multithreading Java，实际上是对某个对象Parlons des problèmes de sécurité des threads du multithreading Java，此锁的对象就是this，本质上Parlons des problèmes de sécurité des threads du multithreading Java操作就是修改this对象头的标记位。
class Counter {
private int count;
synchronized public void increase() {
++this.count;
}
public int getCount() {
return this.count;
}}Copier après la connexion
多线程自增的main方法如下，后面会以相同的栗子介绍synchronized的其他用法，后面就不在列出这段代码了。
public class Main11 {
private static final int CNT = 50000;
private static final Counter counter = new Counter();
public static void main(String[] args) throws InterruptedException {
Thread thread1 = new Thread(() -> {
for (int i = 0; i {
for (int j = 0; j <p>看看Parlons des problèmes de sécurité des threads du multithreading Java：<br><img src="https://img.php.cn/upload/article/000/000/067/6e6c80338fcb268f141a907ecdcadb51-7.png" alt="Parlons des problèmes de sécurité des threads du multithreading Java"><br><strong>方式2：</strong> 使用<code>synchronized</code>关键字对代码段进行Parlons des problèmes de sécurité des threads du multithreading Java，但是需要显式指定Parlons des problèmes de sécurité des threads du multithreading Java的对象。<br> 例如：</p><pre class="brush:php;toolbar:false">class Counter {
private int count;
public void increase() {
synchronized (this){
++this.count;
}
}
public int getCount() {
return this.count;
}}Copier après la connexion
Parlons des problèmes de sécurité des threads du multithreading Java：
方式3： 使用synchronized关键字修饰静态方法，相当于对当前类的类对象进行Parlons des problèmes de sécurité des threads du multithreading Java。
class Counter {
private static int count;
synchronized public static void increase() {
++count;
}
public int getCount() {
return this.count;
}}Copier après la connexion
Parlons des problèmes de sécurité des threads du multithreading Java：
常见的用法差不多就是这些，对于线程Parlons des problèmes de sécurité des threads du multithreading Java（线程拿锁），如果两个线程同时拿一个对象的锁，就会产生锁竞争，两个线程同时拿两个不同对象的锁不会产生锁竞争。
对于synchronized这个关键字，它的英文意思是同步，但是同步在计算机中是存在多种意思的，比如在多线程中，这里同步的意思是“互斥”；而在IO或网络编程中同步指的是“异步”，与多线程没有半点的关系。
synchronized 的工作过程:
- 获得互斥锁
lock
- 从主内存拷贝变量的最新副本到工作的内存
- 执行代码
- 将更改后的共享变量的值刷新到主内存
- 释放互斥锁
unlock
synchronized 同步块对同一条线程来说是可重入的，不会出现自己把自己锁死的问题，即死锁问题，关于死锁后续文章再做介绍。
综上，synchronized关键字Parlons des problèmes de sécurité des threads du multithreading Java有如下性质：互斥性，刷新内存性，可重入性。
synchronized关键字也相当于一把监视器锁monitor lock，如果不Parlons des problèmes de sécurité des threads du multithreading Java，直接使用wait方法（一种线程等待的方法，后面细说），会抛出Parlons des problèmes de sécurité des threads du multithreading Java，引发这个异常的原因就是没有Parlons des problèmes de sécurité des threads du multithreading Java。
2.2.3再析案例
对自增那个代码上锁后，我们再来分析一下为什么加上了所就线程安全了，先列代码：
class Counter {
private int count;
synchronized public void increase() {
++this.count;
}
public int getCount() {
return this.count;
}}public class Main11 {
private static final int CNT = 50000;
private static final Counter counter = new Counter();
public static void main(String[] args) throws InterruptedException {
Thread thread1 = new Thread(() -> {
for (int i = 0; i {
for (int j = 0; j <p>多线程并发执行时，上一次就分析过没有指令集交叉就不会出现问题，因此这里我们只讨论指令交叉后，Parlons des problèmes de sécurité des threads du multithreading Java操作是如何保证线程安全的，不妨记Parlons des problèmes de sécurité des threads du multithreading Java为<code>lock</code>，解锁为<code>unlock</code>，两个线程运行过程如下：<br> 线程1首先拿到目标对象的锁，对对象进行Parlons des problèmes de sécurité des threads du multithreading Java，处于<code>lock</code>状态，当线程2来执行自增操作时会发生阻塞，直到线程1的自增操作完毕，处于<code>unlock</code>状态，线程2才会就绪取执行线程2的自增操作。<br><img src="https://img.php.cn/upload/article/000/000/067/aacb0e52e264f65d74e598d37852834f-10.png" alt="Parlons des problèmes de sécurité des threads du multithreading Java"><br> Parlons des problèmes de sécurité des threads du multithreading Java后线程就是串行执行，与单线程其实没有很大的区别，那多线程是不是没有用了呢？但是对方法Parlons des problèmes de sécurité des threads du multithreading Java后，线程运行该方法才会Parlons des problèmes de sécurité des threads du multithreading Java，运行完该方法就会自动解锁，况且大部分操作并发执行是不会造成线程安全的，只有少部分的修改操作才会有可能导致线程安全问题，因此整体上多线程运行效率还是比单线程高得多。</p><h2>2.3线程不安全的原因</h2><p>首先，线程不安全根源是线程间的调度充满随机性，导致原有的逻辑被改变，造成线程不安全，这个问题无法解决，无可奈何。</p><p>多个线程针对同一资源进行写（修改）操作，并且针对资源的修改操作不是原子性的，可能会导致线程不安全问题，类似于数据库的事务。</p><p>由于编译器的优化，内存可见性无法保证，就是当线程频繁地对同一个变量进行读操作时，会直接从寄存器上读值，不会从内存上读值，这样内存的值修改时，线程就感知不到该变量已经修改，会导致线程安全问题（这是编译器优化的结果，现代的编译器都有类似的优化不止于Java），因为相比于寄存器，从内容中读取数据的效率要小的多，所以编译器会尽可能地在逻辑不变的情况下对代码进行优化，单线程情况下是不会翻车的，但是多线程就不一定了，比如下面一段代码：</p><pre class="brush:php;toolbar:false">import java.util.Scanner;public class Main12 {
private static int isQuit;
public static void main(String[] args) {
Thread thread = new Thread(() -> {
while (isQuit == 0) {
}
System.out.println("线程thread执行完毕!");
});
thread.start();
Scanner sc = new Scanner(System.in);
System.out.println("请输入isQuit的值，不为0线程thread停止执行!");
isQuit = sc.nextInt();
System.out.println("main线程执行完毕!");
}}Copier après la connexion
Parlons des problèmes de sécurité des threads du multithreading Java：
我们从Parlons des problèmes de sécurité des threads du multithreading Java可以知道，输入isQuit后，线程thread没有停止，这就是编译器优化导致线程感知不到内存可见性，从而导致线程不安全。
我们可以使用Parlons des problèmes de sécurité des threads du multithreading Java关键字保证内存可见性。
我们可以使用Parlons des problèmes de sécurité des threads du multithreading Java关键字修饰isQuit来保证内存可见性。
import java.util.Scanner;public class Main12 {
Parlons des problèmes de sécurité des threads du multithreading Java private static int isQuit;
public static void main(String[] args) {
Thread thread = new Thread(() -> {
while (isQuit == 0) {
}
System.out.println("线程thread执行完毕!");
});
thread.start();
Scanner sc = new Scanner(System.in);
System.out.println("请输入isQuit的值，不为0线程thread停止执行!");
isQuit = sc.nextInt();
System.out.println("main线程执行完毕!");
}}Copier après la connexion
Parlons des problèmes de sécurité des threads du multithreading Java：
synchronized与Parlons des problèmes de sécurité des threads du multithreading Java关键字的区别：
synchronized关键字能保证原子性，但是是否能够保证内存可见性要看情况（上面这个栗子是不行的），而Parlons des problèmes de sécurité des threads du multithreading Java关键字只能保证内存可见性不能保证原子性。
保证内存可见性就是禁止编译器做出如上的优化而已。
import java.util.Scanner;public class Main12 {
private static int isQuit;
//锁对象
private static final Object lock = new Object();
public static void main(String[] args) {
Thread thread = new Thread(() -> {
synchronized (lock) {
while (isQuit == 0) {
}
System.out.println("线程thread执行完毕!");
}
});
thread.start();
Scanner sc = new Scanner(System.in);
System.out.println("请输入isQuit的值，不为0线程thread停止执行!");
isQuit = sc.nextInt();
System.out.println("main线程执行完毕!");
}}Copier après la connexion
Parlons des problèmes de sécurité des threads du multithreading Java：
编译器优化除了导致内存可见性感知不到的问题，还有指令重排序也会导致线程安全问题，指令重排序也是编译器优化之一，就是编译器会智能地（保证原有逻辑不变的情况下）调整代码执行顺序，从而提高程序运行的效率，单线程没问题，但是多线程可能会翻车，这个原因了解即可。
3.线程安全的标准类
Java 标准库中很多都是线程不安全的。这些类可能会涉及到多线程修改共享数据, 又没有任何Parlons des problèmes de sécurité des threads du multithreading Java措施。例如，ArrayList，LinkedList，HashMap，TreeMap，HashSet，TreeSet，StringBuilder。
但是还有一些是线程安全的，使用了一些锁机制来控制，例如，Vector (不推荐使用)，HashTable (不推荐使用)，ConcurrentHashMap (推荐)，StringBuffer。
还有的虽然没有Parlons des problèmes de sécurité des threads du multithreading Java, 但是不涉及 “修改”, 仍然是线程安全的，例如String。
在线程安全问题中可能你还会遇到JMM模型，在这里补充一下，JMM其实就是把操作系统中的寄存器，缓存和内存重新封装了一下，其中在JMM中寄存器和缓存称为工作内存，内存称为主内存。
其中缓存分为一级缓存L1，二级缓存L2和三级缓存L3，从L1到L3空间越来越大，最大也比内存空间小，最小也比寄存器空间大，访问速度越来越慢，最慢也比内存的访问速度快，最快也没有寄存器访问快。
4.Object类提供的线程等待方法
除了Thread类中的能够实现线程等待的方法，如join,sleep，在Object类中也提供了相关线程等待的方法。
| 序号 |
方法 |
说明 |
| 1 |
public final void wait() throws InterruptedException |
释放锁并使线程进入WAITING状态 |
| 2 |
public final native void wait(long timeout) throws InterruptedException; |
相比于方法1，多了一个最长等待时间 |
| 3 |
public final void wait(long timeout, int nanos) throws InterruptedException |
相比于方法2，等待的最长时间精度更大 |
| 4 |
public final native void notify(); |
唤醒一个WAITING状态的线程，并Parlons des problèmes de sécurité des threads du multithreading Java，搭配wait方法使用 |
| 5 |
public final native void notifyAll(); |
唤醒所有处于WAITING状态的线程，并Parlons des problèmes de sécurité des threads du multithreading Java（很可能产生锁竞争），搭配wait方法使用 |
上面介绍synchronized关键字的时候，如果不对线程Parlons des problèmes de sécurité des threads du multithreading Java会产生非法监视异常，我们来验证一下：
public class TestDemo12 {
public static void main(String[] args) throws InterruptedException {
Thread thread = new Thread(() -> {
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("执行完毕！");
});
thread.start();
System.out.println("wait前");
thread.wait();
System.out.println("wait后");
}}Copier après la connexion
看看Parlons des problèmes de sécurité des threads du multithreading Java：
果然抛出了一个IllegalMonitorStateException，因为wait方法的执行步骤为：先释放锁，再使线程等待，你现在都没有Parlons des problèmes de sécurité des threads du multithreading Java，那如何释放锁呢？所以会抛出这个异常，但是执行notify是无害的。
wait方法常常搭配notify方法搭配一起使用，前者能够释放锁，使线程等待，后者能获取锁，使线程继续执行，这套组合拳的流程图如下：
现在有两个任务由两个线程执行，假设线程2比线程1先执行，请写出一个多线程程序使任务1在任务2前面完成，其中线程1执行任务1，线程2执行任务2。
这个需求可以使用wait/notify来实现。
class Task{
public void task(int i) {
System.out.println("任务" + i + "完成！");
}}public class WiteNotify {
//锁对象
private static final Object lock = new Object();
public static void main(String[] args) throws InterruptedException {
Thread thread1 = new Thread(() -> {
synchronized (lock) {
Task task1 = new Task();
task1.task(1);
//通知线程2线程1的任务完成
System.out.println("notify前");
lock.notify();
System.out.println("notify后");
}
});
Thread thread2 = new Thread(() -> {
synchronized (lock) {
Task task2 = new Task();
//等待线程1的任务1执行完毕
System.out.println("wait前");
try {
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
task2.task(2);
System.out.println("wait后");
}
});
thread2.start();
Thread.sleep(10);
thread1.start();
}}Copier après la connexion
Parlons des problèmes de sécurité des threads du multithreading Java：
推荐学习：《java视频教程》
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
![Tutoriel de base JavaScript [Opérations DOM BOM que JS doit connaître]](https://img.php.cn/upload/course/000/000/041/61c56ae28d02a390.jpg)
![Analyse approfondie de JavaScript [Le front-end Web doit connaître les compétences de base]](https://img.php.cn/upload/course/000/000/041/61d3ff1c83b43350.jpg)
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
