java之线程死锁和ThreadLocal的使用

简介: java之线程死锁和ThreadLocal的使用

线程死锁

线程死锁是指两个或者两个以上的线程在执行过程中,由于竞争资源或者彼此通信而造成的一种阻塞的现象,若无外力的作用,它们都将无法继续执行下去。

此时应用系统就处于了死锁状态,这些永远在互相等待的线程称为死锁线程。


如下图所示:


在某个状态线程A对对象A进行了加锁,并试图对对象B加锁后继续运行程序;而线程B对对象B进行了加锁,并试图对对象A加锁后继续运行程序。

由于线程A无法释放对象A的锁而又不能对对象B加锁,线程B无法释放对象B的锁而又不能对对象A加锁,因此两个线程处于了相互等待状态,出现死锁

package Runnable;
public class deadlock {
    private Object object1=new Object();
    private Object object2=new Object();
    public Object getObject1() {
        return object1;
    }
    public Object getObject2() {
        return object2;
    }
}
//lock1类
class lock1 implements Runnable{
    private deadlock deadlock1;
    public lock1(deadlock deadlock1) {
        this.deadlock1=deadlock1;
    }
    @Override
    public void run() {
        System.out.println("lock1线程对象正在运行.....");
        //第一步--->lock1所在的线程执行run()方法后获得obj1对象的锁,然后休眠让出CPU的使用权
        synchronized (deadlock1.getObject1()) { //对obj1对象进行加锁
            System.out.println("lock1线程对象对obj1加了锁");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (deadlock1.getObject2()) //对obj2对象进行加锁
            {
                System.out.println("lock1线程对象对obj2加了锁");
            }
        }
        System.out.println("lock1线程对象运行结束.......");
    }
}
//lock2类
class lock2 implements Runnable{
    private deadlock deadlock1;
    public lock2(deadlock deadlock1) {
        this.deadlock1=deadlock1;
    }
    @Override
    public void run() {
        System.out.println("lock2线程对象正在运行.....");
        //第二步--->lock2所在的线程执行run()方法后获得obj2对象的锁,休眠让出CPU的使用权。
        //对obj2对象进行加锁
        synchronized (deadlock1.getObject2()) {
            System.out.println("lock2线程对象对obj2加了锁");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (deadlock1.getObject1()) //对obj2对象进行加锁
            {
                System.out.println("lock2线程对象对obj1加了锁");
            }
        }
        System.out.println("lock2线程对象运行结束.......");
    }
}
//测试类
class deadlock_test{
    public static void main(String[] args) {
        deadlock deadlock1=new deadlock();
        lock1 lock1=new lock1(deadlock1);
        lock2 lock2=new lock2(deadlock1);
        new Thread(lock1).start();
        new Thread(lock2).start();
    }
}

输出:

lock1线程对象正在运行.....
lock1线程对象对obj1加了锁
lock2线程对象正在运行.....
lock2线程对象对obj2加了锁

分析如下:


lock1所在的线程下一次运行时要申请对obj2对象加锁,由于obj2已经被lock2所在的线加锁而且没有释放,所以 lock1 所在的线程就会等待;


lock2所在的线程下一次运行时要申请对obj1对象加锁,由于obj1已经被lock1所在的锁而且没有释放,所以lock2所在的线程就等待


两者之间相互等待对方的锁,从而形成了死锁的状态,程序不再继续执行

因此运行结果中并没有出现“lock1 线程对象运行结束…”和“lock2线程对象运行结束…”这两行信息


ThreadLocal的使用:

ThreadLocal的本质是一个 Map,ThreadLocal中存储的数据和当前线程相关,可以使用 ThreadLocal 解决线程范围内的数据共享问题

ThreadLocal所包含的方法:

void set(T value)   //将值放入线程局部变量中
T get()         //从线程局部变量中获取值
void remove()     //从线程局部变量中移除值
T initialValue()    //返回线程局部变量中的初始值

ThreadLocal简单使用:

假定有这样一个应用场景:有模块 A 和模块 B 或者更多其他的模块,这些模块在一个线程生命周期范围内要访问“同一个”数据,这里的同一个不是指数据的值相同,而是指不能与其他线程对象混淆的数据。

举例:

package Runnable;
//线程类
 class DataThread implements Runnable{
    @Override
    public void run() {
        int x=(int)(Math.random()*100);//随机生成一个100以内的整数
        Mydata_test.threadScopData.set(new MyData(x));//将生成的随机数封装成Data存储到ThreadLocal对象中
        new showdata1().show();//模块1显示数据
        new showdata2().show();//模块2显示数据
    }
}
//封装要显示的数据
class MyData{
    private int number;
    public MyData(int number) {
        this.number = number;
    }
    public int getNumber() {
        return number;
    }
}
//表示输出模块1
class showdata1{
    public void show(){
        MyData data=Mydata_test.threadScopData.get();//从当前线程中拿到数据
        System.out.println("模块A从"+Thread.currentThread().getName()+"取出的数据是:"+data.getNumber());
    }
}
//表示输出模块2
class showdata2{
    public void show(){
        MyData data=Mydata_test.threadScopData.get();//从当前线程中拿到数据
        System.out.println("模块B从"+Thread.currentThread().getName()+"取出的数据是:"+data.getNumber());
    }
}
//测试类
class Mydata_test{
    //创建ThreadLocal对象,存储MyData类型的数据
    public static ThreadLocal<MyData> threadScopData=new ThreadLocal<>();
    public static void main(String[] args) {
        for(int i=0;i<3;i++){
            DataThread dataThread=new DataThread();
            new Thread(dataThread,"线程"+i).start();//创建线程并启动
        }
    }
}

输出:

模块A从线程0取出的数据是:74
模块A从线程2取出的数据是:77
模块A从线程1取出的数据是:48
模块B从线程1取出的数据是:48
模块B从线程2取出的数据是:77
模块B从线程0取出的数据是:74

从运行结果可以看出:模块1和模块2在同一个线对象中从dataThread中取出的数据是相同的,实现了不同模块在同一个线程中获取“同一个”数据的需求

注意:

(1)ThreadLocal为每一个线程提供了一个独立的副本
(2)当一个类中使用了static,如果多线程环境中每个线程要独享这个static变量,此时需要考虑使用 ThreadLocal来存储这个变量。
相关文章
|
4天前
|
安全 Java 调度
Java线程:深入理解与实战应用
Java线程:深入理解与实战应用
24 0
|
1天前
|
缓存 Java
Java并发编程:深入理解线程池
【4月更文挑战第26天】在Java中,线程池是一种重要的并发工具,它可以有效地管理和控制线程的执行。本文将深入探讨线程池的工作原理,以及如何使用Java的Executor框架来创建和管理线程池。我们将看到线程池如何提高性能,减少资源消耗,并提供更好的线程管理。
|
2天前
|
消息中间件 缓存 NoSQL
Java多线程实战-CompletableFuture异步编程优化查询接口响应速度
Java多线程实战-CompletableFuture异步编程优化查询接口响应速度
|
2天前
|
数据采集 存储 Java
高德地图爬虫实践:Java多线程并发处理策略
高德地图爬虫实践:Java多线程并发处理策略
|
3天前
|
缓存 Java
【Java基础】简说多线程(上)
【Java基础】简说多线程(上)
6 0
|
3天前
|
并行计算 算法 安全
Java从入门到精通:2.1.3深入学习Java核心技术——掌握Java多线程编程
Java从入门到精通:2.1.3深入学习Java核心技术——掌握Java多线程编程
|
3天前
|
安全 Java 编译器
是时候来唠一唠synchronized关键字了,Java多线程的必问考点!
本文简要介绍了Java中的`synchronized`关键字,它是用于保证多线程环境下的同步,解决原子性、可见性和顺序性问题。从JDK1.6开始,synchronized进行了优化,性能得到提升,现在仍可在项目中使用。synchronized有三种用法:修饰实例方法、静态方法和代码块。文章还讨论了synchronized修饰代码块的锁对象、静态与非静态方法调用的互斥性,以及构造方法不能被同步修饰。此外,通过反汇编展示了`synchronized`在方法和代码块上的底层实现,涉及ObjectMonitor和monitorenter/monitorexit指令。
17 0
|
3天前
|
监控 安全 Java
在Java中如何优雅的停止一个线程?可别再用Thread.stop()了!
在Java中如何优雅的停止一个线程?可别再用Thread.stop()了!
11 2
|
3天前
|
Java 调度
Java面试必考题之线程的生命周期,结合源码,透彻讲解!
Java面试必考题之线程的生命周期,结合源码,透彻讲解!
31 1
|
3天前
|
安全 Java
Java基础教程(15)-多线程基础
【4月更文挑战第15天】Java内置多线程支持,通过Thread类或Runnable接口实现。线程状态包括New、Runnable、Blocked、Waiting、Timed Waiting和Terminated。启动线程调用start(),中断线程用interrupt(),同步用synchronized关键字。线程安全包如java.util.concurrent提供并发集合和原子操作。线程池如ExecutorService简化任务管理,Callable接口允许返回值,Future配合获取异步结果。Java 8引入CompletableFuture支持回调。

热门文章

最新文章