基础概念

线程安全

线程安全:线程安全是编程中的术语,指某个函数、函数库在并发(Concurrent)环境中被调用时,能够正确地处理多个线程之间的共享变量,使程序功能正确完成。我们就称之为线程安全,反之,线程不安全。

共享变量

进程是分配资源的基本单位,线程是执行的基本单位。多个线程之间可以共享一部分进程中的数据。在JVM中,Java方法区的区域是多个线程共享的数据区域。也就是说,多个线程可以操作保存在堆或者方法区中的同一个数据。保存在堆和方法区中的变量就是Java中的共享变量。

变量类型

Java语言支持的变量类型有:

  • 类变量(静态变量) :独立于方法之外的变量,用 static 修饰。分配在方法区(静态区,跟堆一样,被所有的线程共享)中。无论一个类创建了多少个对象,类只拥有类变量的一份拷贝。在第一次被访问时创建,在程序结束时销毁
  • 实例变量(成员变量)
    独立于方法之外的变量,不过没有 static 修饰。分配在堆内存中,在方法、构造方法、或者语句块被执行的时候创建,当它们执行完成后,变量将会被销毁。
  • 局部变量
    类的方法中的变量,分配在栈内存中,在方法、构造方法、或者语句块被执行的时候创建,当它们执行完成后,变量将会被销毁。
public class Variable{
   
     
    static int allClicks=0;    // 类变量
    String str="hello world";  // 实例变量
    public void method(){
   
     
        int i =0;  // 局部变量
    }
}

线程不安全案例

1、 创建抢票线程;

public class TicketWindow implements Runnable {
   
     

    private static int MAX = 100;

    @Override
    public void run() {
   
     
        // 抢票
        while (MAX > 0) {
   
     
            try {
   
     
                System.out.println(Thread.currentThread().getName() + "抢到第" + MAX-- + "张票");
                Thread.sleep(100);
            } catch (InterruptedException e) {
   
     
                e.printStackTrace();
            }
        }
    }

    public TicketWindow() {
   
     

    }
}

1、 开启三个线程同时抢票;

public class TicketWindowTest {
   
     
    public static void main(String[] args) {
   
     
        TicketWindow ticketWindow = new TicketWindow();

        Thread t1 = new Thread(ticketWindow, "001");
        Thread t2 = new Thread(ticketWindow, "002");
        Thread t3 = new Thread(ticketWindow, "003");

        t1.start();
        t2.start();
        t3.start();
    }
}

1、 启动抢票,出现线程不安全问题:多个线程会抢同一张票;
 

synchronized

概念

多个线程同时操作共享资源时会引起的线程不安全问题。在JDK1.5版本以前,要解决这个问题需要使用synchronized关键字,synchronized提供了一种排他机制,也就是在同一时间只能有一个线程执行某些操作。

官网解释

 
synchronized关键字可以实现一个简单的策略来防止线程干扰和内存一致性错误,如果一个对象对多个线程是可见的,那么对该对象的所有读或者写都将通过同步的方式来进行,具体表现如下:

  • synchronized关键字提供了一种锁的机制,能够确保共享变量的互斥访问,从而防止数据不一致问题的出现。
  • synchronized关键字包括monitor enter 和 monitor exit两个JVM指令,它能够保证在任何时候任何线程执行到monitor enter成功之前都必须从主内存中获取数据,而不是从缓存中,在monitor exit运行成功之后,共享变量被更新后的值必须刷入主内存。
  • synchronized的指令严格遵守java happens-before规则,一个monitor exit 指令之前必定要有一个monitor enter。

用法

synchronized可以用于对代码块或方法进行修饰,而不能够用于对class 以及变量进行修饰。下面将抢票的程序进行优化,解决不安全问题。

同步方法

在方法修饰符后添加synchronized关键字

    public synchronized void ticket(){
   
     
            try {
   
     
                System.out.println(Thread.currentThread().getName() + "抢到第" + MAX-- + "张票");
                Thread.sleep(300);
            } catch (InterruptedException e) {
   
     
                e.printStackTrace();
            }
    }

同步代码块

synchronized代码块,并添加一个锁对象。

public class TicketWindow implements Runnable {
   
     

    private static int MAX = 100;

    private final Object MUTEX = new Object();

    public void run() {
   
     
        // 抢票
        while (MAX > 0) {
   
     
            synchronized (MUTEX) {
   
     
                System.out.println(Thread.currentThread().getName() + "抢到第" + MAX-- + "张票");
            }
            try {
   
     
                TimeUnit.MILLISECONDS.sleep(100);
            } catch (Exception e) {
   
     
                e.printStackTrace();
            }
        }
    }

注意事项

1、 使用synchronized代码块时,锁对象不能为null;

    private final Object MUTEX = new Object();

1、 作用域;
由于synchronized关键字存在排他性,也就是说所有的线程必须串行地经过synchronized保护的共享区域,如果synchronized作用域越大,则代表着其效率越低,甚至还会丧失并发的优势,synchronized关键字应该尽可能地只作用于共享资源(数据)的读写作用域。
上述同步代码块案例应该这么写,否则会出现-1:

            synchronized (MUTEX) {
   
     
                if (MAX > 0) {
   
     
                    System.out.println(Thread.currentThread().getName() + "抢到第" + MAX-- + "张票");
                }else {
   
     
                    break;
                }
            }

1、 锁对象;
同步代码块:传入的对象锁
同步方法:非静态方法为对象实例this作为对象锁,静态方法是使用class类锁 2、 同一个Runable实例;
Runnable实例作为线程逻辑执行单元传递给Thread时,应为同一个实例,不然起起到互斥的作用。 3、 多个锁的交叉导致死锁;
多个锁的交叉很容易引起线程出现死锁的情况

            synchronized (MUTEX) {
   
     
                System.out.println(Thread.currentThread().getName() + "抢到第" + MAX-- + "张票");
                synchronized (MUTEX02) {
   
     
                    System.out.println(Thread.currentThread().getName() + "抢到第" + MAX-- + "张票");
                }
            }