基础概念
线程安全
线程安全:线程安全是编程中的术语,指某个函数、函数库在并发(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-- + "张票");
}
}