600字范文,内容丰富有趣,生活中的好帮手!
600字范文 > Java并发编程系列(4)-线程安全及synchronized

Java并发编程系列(4)-线程安全及synchronized

时间:2021-12-07 00:30:50

相关推荐

Java并发编程系列(4)-线程安全及synchronized

基础概念

线程安全

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

共享变量

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

变量类型

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

类变量(静态变量):独立于方法之外的变量,用 static 修饰。分配在方法区(静态区,跟堆一样,被所有的线程共享)中。无论一个类创建了多少个对象,类只拥有类变量的一份拷贝。在第一次被访问时创建,在程序结束时销毁

实例变量(成员变量)

独立于方法之外的变量,不过没有 static 修饰。分配在堆内存中,在方法、构造方法、或者语句块被执行的时候创建,当它们执行完成后,变量将会被销毁。

局部变量

类的方法中的变量,分配在栈内存中,在方法、构造方法、或者语句块被执行的时候创建,当它们执行完成后,变量将会被销毁。

public class Variable{static int allClicks=0; // 类变量String str="hello world"; // 实例变量public void method(){int i =0; // 局部变量}}

线程不安全案例

创建抢票线程

public class TicketWindow implements Runnable {private static int MAX = 100;@Overridepublic void run() {// 抢票while (MAX > 0) {try {System.out.println(Thread.currentThread().getName() + "抢到第" + MAX-- + "张票");Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}}public TicketWindow() {}}

开启三个线程同时抢票

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();}}

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

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();}}}

注意事项

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

private final Object MUTEX = new Object();

作用域

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

上述同步代码块案例应该这么写,否则会出现-1:

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

锁对象

同步代码块:传入的对象锁

同步方法:非静态方法为对象实例this作为对象锁,静态方法是使用class类锁同一个Runable实例

Runnable实例作为线程逻辑执行单元传递给Thread时,应为同一个实例,不然起起到互斥的作用。多个锁的交叉导致死锁

多个锁的交叉很容易引起线程出现死锁的情况

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

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。