03、Java多线程：线程安全问题-6ren

03、Java多线程：线程安全问题

转载作者：大佬之路更新时间：2024-01-31 14:11:35

3.1 线程安全问题

非线程安全：主要是指多个线程对同一个对象的实例变量进行操作时，会出现值被更改，值不同步的问题。

线程安全：原子性、可见性、有序性

3.2 原子性

原子(Atomic)就是不可分割的意思。

原子操作的不可分割有两层含义：1）访问（读、写）某个共享变量的操作从其他线程来看，该操作要么已经执行完毕，要么尚未发生。即其他线程看不到当前操作的中间结果。2）访问同一组共享变量的原子操作，是不能够交叉的。

Java有两种方式实现原子性：一种是使用锁，另一种是利用处理器的CAS（Compare and Swap）指令。

锁具有排它性，保证共享变量在某一时刻只能被一个线程访问。

CAS指令直接在硬件（处理器和内存）层次上实现原子性。看作是硬件锁。

以下这段代码因为没有考虑原子性，导致这两个线程读取的num值有时候是一样的（因为num++其实是分步执行的）。

package threadSafe;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

public class Test01 {

    public static void main(String[] args) {
        //启动两个线程，不断调用getNum()方法
        MyInt myInt = new MyInt();

        for(int i = 1; i <= 2; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    while(true) {
                        System.out.println(Thread.currentThread().getName() + "->" + myInt.getNum());
                        try {
                            TimeUnit.MILLISECONDS.sleep(100);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
        }
    }

    static class MyInt{
        int num;
        public int getNum() {
            return num++;
        }
    }
}

3.3 可见性

在多线程环境中，一个线程对某个共享变量进行更新后，后续其他的线程可能无法立即读取到这个更新后的结果。这是线程安全问题的另一种形式：可见性（visibility）。

如果一个线程对共享变量更新后，后续访问该变量的其他线程可以马上读到更新的结果，称这个线程对共享变量的更新对其他线程具有可见性；反之称为没有可见性。

多线程程序可能因为可见性，导致其他线程读取到了旧数据（脏数据）。

下面这段代码可能出现这种情况：在main线程中调用了myTask的cancel()方法修改toCancel为true，但是myTask线程看不到。
原因： 1、 JIT及时编译器可能对while循环进行优化：

if(!toCancel) {
    while(true) {
        doSomething();
    }
}

2、可能与计算机的存储系统有关假设main线程和myTask线程分别运行在两个cpu上，而一个cpu不能立即读取到另一个cpu中的数据；

package threadSafe;

import createThread.p1.MyThread;

import java.util.concurrent.TimeUnit;

//测试线程的可见性
public class Test02 {

    public static void main(String[] args) throws InterruptedException {
        MyTask myTask = new MyTask();
        new Thread(myTask).start();
        TimeUnit.MILLISECONDS.sleep(1000);
        myTask.cancel();
    }

    static class MyTask implements Runnable {
        private boolean toCancel = false;

        @Override
        public void run() {
            while(!toCancel) {
                doSomething();
            }
            if(toCancel) System.out.println("任务被取消");
            else System.out.println("任务正常结束");
        }

        private boolean doSomething() {
            System.out.println("执行某个任务");
            try {
                TimeUnit.MILLISECONDS.sleep(1000); //模拟任务执行需要的时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return true;
        }

        public void cancel() {
            toCancel = true;
        }
    }
}