05. java线程基础

05. java线程基础

01. 线程相关概念

1. 程序

​ 是为完成特定任务、用某种语言编写的一组指令的集合。简单来说:就是我们写的代码

2. 进程

  1. 进程是指运行中的程序,比如我们使用微信,就启动了一个进程,操作系统会为该进程分配内存空间。当我们使用迅雷,又启动了一个进程,操作系统将为迅雷分配新的内存空间
  2. 进程是程序的一次执行过程,或是正在运行的一个程序。是动态过程:有它自身的产生,存在和消亡的过程

3. 什么是线程

  1. 线程是由进程创建的,是进程的一个实体
  2. 一个进程可以有多个线程
  3. 后面会把多线程加入到坦克大战中

4. 其他相关概念

  1. 单线程:同一个时刻,只允许执行一个线程
  2. 多线程:同一个时刻,可以执行多个线程,比如:一个qq线程,可以同时打开多个聊天窗口,一个迅雷可以同时下载多个文件
  3. 并发:同一个时刻,多个任务交替执行,造成一种“貌似同时“的错觉,简单地说,单核CPU实现的多任务就是并发
  4. 并行:同一个时刻,多个任务同时执行。多核CPU可以实现并行。
  5. 要查看自己的核心数量可以看设备管理器,假如要在idea中查看,我们可以写一串代码
public class CpuNum {
    public static void main(String[] args) {
        Runtime runtime = Runtime.getRuntime();
        //1. 获取当前cpu数量/核心数量
        int cpuNums = runtime.availableProcessors();
        System.out.println("当前cpu核心个数" + cpuNums);
    }
}

02. 线程基本使用

1. 创建线程的两种方式

​ 在java中线程来使用有两种方法

  1. 继承Thread类,重写run方法
  2. 实现Runnable接口,重写run方法

2. 线程应用案例-继承Thread

  1. 请编写程序,开启一个线程,该线程每隔一秒。在控制台输出“喵喵,我是小猫咪”
  2. 当输出8次 喵喵,我是小猫咪,结束该线程
  3. 使用JConsole 监控线程执行情况,并画出线程示意图
    1. 我们可以修改下面代码中main进程中for循环次数为60,cat类中循环次数改为80
    2. 然后,我们运行程序,在终端输入jconsole,在弹出的界面中,建立连接,查看线程
    3. 不会使用也没有关系,只要记住主线程结束后,有子线程继续运行,不会导致程序的结束
public class Thread01 {
    public static void main(String[] args) throws InterruptedException {
        //4. 创建一个Cat对象,可以当做线程使用
        Cat cat = new Cat();
        cat.start();//4.1 启动线程
        /*  (1)
            public synchronized void start() {
                start0();
            }
            (2)
            //start0() 是本地方法,是JVM调用,底层是c/c++ 实现的
            //真正实现多线程的效果,是start0(), 而不是 run
            private native void start0();
         */
        //4.2 说明:当main进程启动一个子线程 Thread-0,主线程不会堵塞,会继续执行。
        // 比如我在后面继续写了一些代码.
        //4.3 主线程和子线程是交替执行。。

        System.out.println("主线程继续执行" + Thread.currentThread().getName());//名字 mian
        for (int i = 0; i < 60; i++) {
            System.out.println("主线程 i=" + i);
            //让主线程休眠
            Thread.sleep(1000);
        }
    }
}
//1. 当一个类继承了 Thread类,该类就可以当做线程使用
//2. 我们会重写run方法,写上自己的业务代码
//3. Thread 类 实现了 Runnable 接口的run方法
/*
    @Override
    public void run() {
        if (target != null) {
            target.run();
        }
    }
 */
class Cat extends Thread {
    int times = 0;
    @Override
    public void run() {//重写run方法,写上自己的业务逻辑
        while (true) {
            //3.1 该线程每隔一秒,在控制台输出“喵喵,我是小猫咪”
            System.out.println("喵喵,我是小猫咪" + (++times) + "线程名" + Thread.currentThread().getName());
            //3.2 让该线程休眠1秒 异常处理使用快捷键 ctrl + alt + t
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if (times == 80) {
                break;
            }
        }
    }
}
  1. 为什么没在main方法中使用cat.start(); 没有直接使用run方法,因为你在main中调用run方法,只是单纯的调用了一个方法,而没有启动线程
  2. 线程示意图
    在这里插入图片描述
  3. start() 方法调用 start0()方法后, 该线程并不一定会立马执行, 只是让线程变成了可运行状态.具体什么时候执行,取决于cpu, 由cpu统一调度

3. 线程应用案例-实现Runnable接口

1.基本说明
  1. java是单继承的, 在某些情况下一个雷可能已经继承了某个父类, 这时再用继承Thread类方法来创建线程显然不可能了
  2. java设计者们提供了另外一个方式创建线程,就是通过实现Runnable接口来创建线程
2. 应用案例

​ 请编写程序,该程序可以每隔1秒。在控制台输出“hi!",当输出10次后,自动退出。使用Runnable接口的方式实现

  1. 这里我们不能直接使用start,使用了设计模式【代理模式】=> 代码模拟实现Runnable接口 开发线程机制
public class Thread02 {
    public static void main(String[] args) {
//        Dog dog = new Dog();
//        //1. dog.start(); 这里不能使用start
//        //1.1 创建了Thread对象,把dog对象(实现Runnable),放入Thread
//        Thread thread = new Thread(dog);
//        thread.start();
        
		//线程代理
        Tiger tiger = new Tiger();
        Proxy proxy = new Proxy(tiger);
        proxy.start();
    }
}
// 2. 线程代理类,模拟了一个最简单的Thread类
class Proxy implements Runnable {
    //2.1 可以把proxy类当做 ThreadProxy(Thread代理)
    private Runnable target = null; //属性 类型是Runnable
    @Override
    public void run() {
        if (target != null) {
            target.run();//动态绑定Tiger
        }
    }
    public Proxy(Runnable target) {
        this.target = target;
    }
    public void start() {
        start0();//这个方法真正实现多线程方法
    }

    private void start0() {
        run();
    }
}
class Animal {}
class Tiger extends Animal implements Runnable {

    @Override
    public void run() {
        System.out.println("老虎叫");
    }
}

class Dog implements Runnable {
    int count = 0;
    public Dog() {
    }

    @Override
    public void run() {
        while (true) {
            System.out.println("小狗汪汪叫" + (++count) + Thread.currentThread().getName());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if (count == 10) {
                break;
            }
        }
    }
}

4. 线程使用应用案例-多线程执行

​ 请编写一个程序 ,创建两个线程,一个线程每隔1秒输出“hello,world” 输出 10次,退出,一个线程每隔1秒输出 “hi”,输出5次退出(目的主要在于练习)

package com.yzjedu.threaduse;

/**
 * 03. main线程启动两个子线程
 */
public class Thread03 {
    public static void main(String[] args) {
        T1 t1 = new T1();
        T2 t2 = new T2();
        Thread thread = new Thread(t1);
        Thread thread1 = new Thread(t2);
        thread.start();//启动第一个线程
        thread1.start();//启动第二个线程
    }
}
class T1 implements Runnable {
    int count = 0;
    @Override
    public void run() {
        while (true) {
            System.out.println("hello world" + (++count));
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if (count == 10) {
                break;
            }
        }
    }
}
class T2 implements Runnable {
    int count = 0;
    @Override
    public void run() {
        while (true) {
            System.out.println("hi" + (++count));
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if (count == 5) {
                break;
            }
        }
    }
}

03. 继承Thread实现Runnable接口的区别

1. 主要区别

  1. 从java设计者来看,通过继承Thread或者实现Runnable接口来创建线程本质上昂没有区别,从jdk帮助文档我们可以看到Thread类本身就实现了Runnable接口
  2. 实现Runnable接口方式更加适合多个线程共享一个资源的情况,并且避免了单继承的限制

例如:

T3 = new T3("hello");
Thread thread01 = new Thread(t3);
Thread thread02 = new Thread(t3);
thread01.start();
thread03.start();
//两个线程同时执行一个对象t3,共享资源

2. 案例

[售票系统],编程模拟三个售票窗口售票100,分别使用继承Thread和实现Runnable方式、并分析有什么问题?

/**
 * 使用多线程,模拟三个窗口同时售票100张
 */
public class SellTicket {
    public static void main(String[] args) {
        //1. 继承Thread
//        //测试
//        SellTicket01 sellTicket01 = new SellTicket01();
//        SellTicket01 sellTicket02 = new SellTicket01();
//        SellTicket01 sellTicket03 = new SellTicket01();
//        //这里出现了票数超卖问题
//        sellTicket01.start();
//        sellTicket02.start();
//        sellTicket03.start();
        //2. 实现Runnable接口
        SellTicket02 sellTicket02 = new SellTicket02();
        // 这里还是出现了票数超卖问题
        new Thread(sellTicket02).start();
        new Thread(sellTicket02).start();
        new Thread(sellTicket02).start();

    }
}
//1. 使用Thread方式
class SellTicket01 extends Thread {
    private int ticketNum = 100;//让多个线程共享 ticketNum
    @Override
    public void run() {
        while (true) {
            if (ticketNum <= 0) {
                System.out.println("售票结束");
                break;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口 " + Thread.currentThread().getName()+"售出一张票"
                    + " 剩余票数" + (--ticketNum));
        }
    }
}
// 实现接口方式
class SellTicket02 implements Runnable {
    private int ticketNum = 100;
    @Override
    public void run() {
        while (true) {
            if (ticketNum <= 0) {
                System.out.println("售票结束");
                break;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口 " + Thread.currentThread().getName()+"售出一张票"
                    + " 剩余票数" + (--ticketNum));
        }
    }
}

​ 我们发现运行这个程序后有票数超卖的问题,这个不是代码的问题,而是线程安全的问题,我们在后面的内容中会解决这个问题

04. 线程终止

1. 基本说明

  1. 当线程完成任务后,会自动退出
  2. 还可以通过使用变量来控制run方法退出的方式停止线程,即通知方式

2. 应用案例

需求:启动一个线程t,要求在main线程中停止线程t,用编程实现

/**
 * 线程终止问题
 */
public class ThreadExit_ {
    public static void main(String[] args) throws InterruptedException {
        T t1 = new T();
        t1.start();
        //1.1 如果希望main线程去控制 t1 线程的终止,必须可以修改
        //1.2 让 t1 退出run方法,从而终止 t1线程 -> 通知方式
        //1.3 方法就是在主线程中 修改loop为false

        //1.4 让主线程休眠10 秒,再通知线程退出
        System.out.println("主线程休眠10秒");
        Thread.sleep(10 * 1000);
        t1.setLoop(false);
    }
}
class T extends Thread {
    private int count = 0;
    //1. 设置一个变量
    private boolean loop = true;
    @Override
    public void run() {
        while (loop) {
            System.out.println("Tthread 运行中" + (++count));
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void setLoop(boolean loop) {
        this.loop = loop;
    }
}

05. 线程常用方法

1. 常用方法第一组

  1. setName:设置线程名称,使之与参数name相同
  2. getName:返回该线程的名称
  3. start:该线程开始执行;java虚拟机底层调用该线程的 start0方法
  4. run:调用线程对象run方法;
  5. setPriority:更改线程的优先级
  6. getPriority:获取线程的优先级
  7. sleep:在指定的毫秒数内让当前正在执行的线程休眠(暂停执行)
  8. interrupt:中断线程
1. 注意事项和细节
  1. start底层会创建新的线程,调用run,run就是一个简单的方法调用,不会启动新线程
  2. 线程优先级的范围
  3. interrupt,中断线程,但没有真正的结束线程。所以一般用于中断正在休眠线程
  4. sleep:线程的静态方法,使当前线程休眠
2. 应用案例
/**
 * 常用方法
 */
public class ThreadMethod01 {
    public static void main(String[] args) throws InterruptedException {
        //测试
        T t = new T();
        t.setName("小白");
        t.setPriority(Thread.MIN_PRIORITY);//1
        t.start();//启动线程

        //我们让主线层打印5次够了,然后我们中断子线程的休眠
        for (int i = 0; i < 5; i++) {
            Thread.sleep(1000);
            System.out.println("继续吃" + (i + 1));
        }
        System.out.println(t.getName() + "优先级是" + t.getPriority());
        t.interrupt();//当执行到这里,就会中断 t线程的休眠
    }
}

class T extends Thread { //自定义线程类
    @Override
    public void run() {
        while (true) {
            for (int i = 0; i < 100; i++) {
                //Thread.currentThread().getName() 获取当前线程的名称
                System.out.println(Thread.currentThread().getName() + "吃饺子···" + i);
            }
            try {
                Thread.sleep(20000);//5秒
            } catch (InterruptedException e) {
                //当该线程执行到一个interrupt方法时,就会 catch一个异常,可以加入自己的业务代码
                //InterruptedException 是捕获到一个中断异常
                System.out.println(Thread.currentThread().getName() + "被interrupt了");
            }
        }
    }
}

2. 常用方法第二组

  1. yield:线程的礼让。让出cpu,让其他线程执行,但礼让的时间不确定,所以不一定礼让成功
  2. join:线程的插队。插队的线程一旦插队成果,则可定先执行完插入的线程所有的任务
1. 测试案例

案例:创建一个子线程,每隔1s吃一个包子, 吃20个,主线程每隔1秒吃一个包子,吃20个。当主线程吃了5个包子的时候,让子线程吃。

public class ThreadMethod02 {
    public static void main(String[] args) throws InterruptedException {
        T2 t2 = new T2();
        t2.start();

        for (int i = 1; i <= 20 ; i++) {
            Thread.sleep(1000);
            System.out.println("主线程吃了 " + i + " 包子");
            if (i == 5) {
                System.out.println("主线程让子线程先吃");
                t2.join();//这里相当于让t2 线程先执行完毕
//                t2.yield();//这里礼让不一定成功
                System.out.println("主线程让子线程接着吃");
            }
        }
    }
}
class T2 extends Thread {
    @Override
    public void run() {
        for (int i = 1; i <= 20; i++) {
            try {
                Thread.sleep(1000);//休眠一秒
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("子线程吃了 " + i + " 包子");
        }
    }
}
2. 综合练习

要求:

  1. 主线程每隔1s,输出hi,一共10次
  2. 当输出到hi 5时,启动一个子线程(要求实现Runnable),每隔1s输出hello ,等该线程输出10次hello后,退出
  3. 主线程继续输出hi,直到主线程退出
public class ThreadMethodExercise {
    public static void main(String[] args) throws InterruptedException {
        T3 t3 = new T3();
        Thread threadT3 = new Thread(t3);
        for (int i = 1; i <= 10 ; i++) {
            System.out.println("hi" + i);
            Thread.sleep(1000);
            if (i == 5) {
                threadT3.start();//启动了线程,输出hello
                threadT3.join();//立即将t3子线程,先执行
            }
        }
    }
}
class T3 implements Runnable {
    @Override
    public void run() {
        for (int i = 1; i <= 10 ; i++) {
            System.out.println("hello" + i);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

3. 用户线程和守护线程

  1. 用户线程:也叫工作线程,当线程的任务执行完或通知方式 结束
  2. 守护线程:一般是为工作线程服务的,当所有的用户线程结束,守护线程自动结束
    1. 在我们前面的学习内容中,我们知道当主线程结束的时候,子线程里如果有无限循环等等,那么子线程不会自动结束
    2. 守护线程的作用就是:在主线程结束后,无论子线程是否继续执行完毕都会自动结束
  3. 常见的守护线程:垃圾回收机制
1. 应用案例

​ 我们测试如何将一个线程设置成守护线程

public class ThreadMethod03 {
    public static void main(String[] args) throws InterruptedException {
        MyDaemonThread myDaemonThread = new MyDaemonThread();
        //1. 如果我们希望当main线程结束后,子线程自动结束
        // 只需要将子线程设为守护线程
        myDaemonThread.setDaemon(true);
        myDaemonThread.start();

        for (int i = 1; i <= 10; i++) {
            System.out.println("主线程辛苦的工作");
            Thread.sleep(1000);

        }
    }
}
class MyDaemonThread extends Thread {
    @Override
    public void run() {
        for (; ; ) {//无限循环
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("子线程在辛苦的工作...");
        }
    }
}

06. 线程的生命周期

1. JDK中用Thread.State 枚举表示了线程的几种状态

在这里插入图片描述

2. 线程状态转换图

在这里插入图片描述

3. 写程序查看线程状态

public class ThreadState_ {
    public static void main(String[] args) throws InterruptedException {
        T t = new T();
        System.out.println(t.getName() + "状态 " + t.getState());
        t.start();

        while (Thread.State.TERMINATED != t.getState()) {
            System.out.println(t.getName() + "状态 " + t.getState());
            Thread.sleep(500);
        }
        System.out.println(t.getName() + "状态 " + t.getState());
    }
}
class T extends Thread {
    @Override
    public void run() {
        while (true) {
            for (int i = 0; i < 10; i++) {
                System.out.println("hi" + i);
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            break;
        }
    }
}

07. 线程同步

1. Synchronized

1. 线程同步机制
  1. 在多线程编程,-些敏感数据不允许被多个线程同时访问,此时就使用同步访问技术,保证数据在任何同一时刻,最多有一个线程访问,以保证数据的完整性。
  2. 也可以这样理解:线程同步,即当有一个线程在对内存进行操作时,其他线程都不可以对这个内存地址进行操作,直到该线程完成操作,其他线程才能对该内存地址进行操作.
2. 同步具体方法-Synchronized
  1. 同步代码块
    synchronized (对象) {//得到对象的锁,才能操作同步代码
    //需要同步代码;
    }
  2. synchronized还可以放在方法声明中,表示整个方法-为同步方法
    public synchronized void m (String name) {
    //需要同步代码
    }
  3. 假设有一个办公室里只有一个咖啡机,有多个同事想在同一时刻取咖啡。为了防止在取咖啡的过程中发生混乱,我们需要引入线程同步。
    1. 无线程同步(可能会发生问题): 就好像办公室里的每个同事都可以随时走到咖啡机前取咖啡,而没有任何限制。这样可能导致多个人同时操作咖啡机,可能发生倒咖啡、撞到一起的情况。
    2. 使用线程同步: 现在我们在咖啡机前设置一扇门,每个同事在取咖啡前都需要先把门关上(上锁),完成取咖啡后再把门打开(解锁)。这样,一次只能有一个同事进入咖啡机区域,避免了混乱。
  4. 使用synchronized解决前面的售票系统的超卖问题
public class SellTicket {
    public static void main(String[] args) {
        //1. 继承Thread
//        //测试
//        SellTicket01 sellTicket01 = new SellTicket01();
//        SellTicket01 sellTicket02 = new SellTicket01();
//        SellTicket01 sellTicket03 = new SellTicket01();
//        //这里出现了票数超卖问题
//        sellTicket01.start();
//        sellTicket02.start();
//        sellTicket03.start();

//        //2. 实现Runnable接口
//        SellTicket02 sellTicket02 = new SellTicket02();
//        // 这里还是出现了票数超卖问题
//        new Thread(sellTicket02).start();
//        new Thread(sellTicket02).start();
//        new Thread(sellTicket02).start();
        
        //3.2 线程同步
        SellTicket03 sellTicket03 = new SellTicket03();
        new Thread(sellTicket03).start();
        new Thread(sellTicket03).start();
        new Thread(sellTicket03).start();


    }
}

//3. 实现接口方式,使用synchronized实现线程同步
class SellTicket03 implements Runnable {
    private int ticketNum = 100;
    private boolean loop = true;
    public synchronized void sell() { //3.1 同步方法,在同一个时刻只能有一个线程来操作,run方法
        if (ticketNum <= 0) {
            System.out.println("售票结束");
            loop = false;
            return;
        }
        try {
            Thread.sleep(50);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("窗口 " + Thread.currentThread().getName()+"售出一张票"
                + " 剩余票数" + (--ticketNum));
    }
    @Override
    public void run() {
        while (loop) {
            sell();
        }
    }
}

//1. 使用Thread方式
class SellTicket01 extends Thread {
    private int ticketNum = 100;//让多个线程共享 ticketNum
    @Override
    public void run() {
        while (true) {
            if (ticketNum <= 0) {
                System.out.println("售票结束");
                break;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口 " + Thread.currentThread().getName()+"售出一张票"
                    + " 剩余票数" + (--ticketNum));
        }
    }
}

// 2. 实现接口方式
class SellTicket02 implements Runnable {
    private int ticketNum = 100;
    @Override
    public void run() {
        while (true) {
            if (ticketNum <= 0) {
                System.out.println("售票结束");
                break;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口 " + Thread.currentThread().getName()+"售出一张票"
                    + " 剩余票数" + (--ticketNum));
        }
    }
}

3. 分析同步原理

在这里插入图片描述

08. 互斥锁

1. 基本介绍

  1. Java语言中,引入了对象互斥锁的概念,来保证共享数据操作的完整性。
  2. 每个对象都对应一个可称为“互斥锁”的标记,这个标记用来保证在任意时刻,只能有一个线程访问对象
  3. 关键字synchronized来与对象的互斥锁联系。当某个对象用synchronized修饰时,表明该对象在任意时刻只能由一个线程访问
  4. 同步的局限性:导致程序的执行效率降低
  5. 同步方法(非静态的)的锁可以是this,也可以是其他对象(要求是同一个对象)
  6. 同步方法(静态的)的锁为前类本身。类.class

2. 使用互斥锁解决售票问题

代码块加锁,和方法上加锁

public class SellTicket {
    public static void main(String[] args) {
        SellTicket03 sellTicket03 = new SellTicket03();
        new Thread(sellTicket03).start();
        new Thread(sellTicket03).start();
        new Thread(sellTicket03).start();


    }
}

//3. 实现接口方式,使用synchronized实现线程同步
class SellTicket03 implements Runnable {
    private int ticketNum = 100;
    private boolean loop = true;
    
    //5. 同步方法(静态的)的锁为当前类本身
    //5.1 public synchronized static void m1() {} 锁加在SellTicket03.class
    //5.2 如果在静态方法中,实现一个同步代码块
    public synchronized static void m1() {}
    public static void m2() {
        synchronized (SellTicket03.class) {
            System.out.println("hhhh");
        }
    }
    Object object = new Object();
    //4. 说明
    //4.1 public synchronized void sell() {} 就是一个同步方法
    //4.2 这时锁在 this对象
    //4.3 也可以在代码块上写 synchronized
    public /*synchronized*/ void sell() { //3.1 同步方法,在同一个时刻只能有一个线程来操作,run方法
        synchronized (/*this*/ object) {
            if (ticketNum <= 0) {
                System.out.println("售票结束");
                loop = false;
                return;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口 " + Thread.currentThread().getName() + "售出一张票"
                    + " 剩余票数" + (--ticketNum));
        }
    }
    @Override
    public void run() {
        while (loop) {
            sell();
        }
    }
}

3. 注意事项和细节

  1. 同步方法如果没有使用static修饰,默认锁的对象为this
  2. 如果方法使用static修饰,默认锁的对象:当前类.class
  3. 实现步骤:
    1. 需要先分析上锁的代码
    2. 选择同步代码块或同步方法
    3. 要求多个线程的锁对象为同一个就行

09. 线程死锁

1. 基本介绍

​ 多个线程都占用了对方的锁资源,但不肯相让,导致了死锁,在编程中是一定要避免死锁的发生

2. 应用案例

妈妈:你先完成作业,才让你玩手机
小明:你先让我玩手机,我才完成作业

3. 模拟线程死锁

package com.yzjedu.synchronized_;

/**
 * 12. 模拟线程死锁
 */
public class DeadLock_ {
    public static void main(String[] args) {
        //模拟一个锁现象
        DeadLockDemo A = new DeadLockDemo(true);
        A.setName("A线程");
        DeadLockDemo B = new DeadLockDemo(false);
        B.setName("B线程");
        A.start();
        B.start();
    }
}

//线程
class DeadLockDemo extends Thread {
    static Object o1 = new Object();//保证多线程,共享一个对象,这里使用static
    static Object o2 = new Object();
    boolean flag;

    public DeadLockDemo(boolean flag) { //构造器
        this.flag = flag;
    }

    @Override
    public void run() {

        //下面业务逻辑的分析
        //1. 如果flag 为 T, 线程A就会得到/持有o1 对象锁,然后尝试获取o2 对象锁
        //2. 如果线程A 得不到o2对象锁,就会Blocked
        //3. 如果flag 为 F,线程B就会先得到/持有o2 对象锁,然后尝试获取o1 对象锁
        //4. 如果线程B 得不到 o1 对象锁,就会Blocked
        if (flag) {
            synchronized (o1) {//对象互斥锁,下面就是同步代码
                System.out.println(Thread.currentThread().getName() + " 进入1");
                synchronized (o2) {//这里获得li对象的监视权
                    System.out.println(Thread.currentThread().getName() + " 进入2");
                }
            }
        } else {
            synchronized (o2) {
                System.out.println(Thread.currentThread().getName() + " 进入3");
                synchronized (o1) {
                    System.out.println(Thread.currentThread().getName() + " 进入4");
                }
            }
        }

    }
}

10. 释放锁

1. 下面的操作会释放锁

  1. 当前线程的同步方法、同步代码块执行结束
    案例: . 上厕所,完事出来
  2. 当前线程在同步代码块、同步方法中遇到break、 return。
    案例:没有正常的完事,经理叫他修改bug,不得已出来
  3. 当前线程在同步代码块、同步方法中出现了未处理的Error或Exception,导致异常结束
    案例:没有正常的完事,发现忘带纸,不得已出来
  4. 当前线程在同步代码块,同步方法中执行了线程wait()方法,当前线程暂停,并释放锁
    案例:没有正常完事,觉得需要酝酿下,所以出来等会再进去

2. 下面的操作不会释放锁

  1. 线程执行同步代码块或同步方法时,程序调用Thread.sleep()、Thread.yield()方法暂停当前线程的执行,不会释放锁
    案例:上厕所,太困了,在坑位上眯了一会
  2. 线程执行同步代码块时,其他线程调用了suspend()方法将该线程挂起,该线程不会释放锁。
    提示:应该尽量避免使用suspend()和resume()来控制线程,方法不再推荐使用

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/354666.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【代码随想录】LC 242. 有效的字母异位词

文章目录 前言一、题目1、原题链接2、题目描述 二、解题报告1、思路分析2、时间复杂度3、代码详解 前言 本专栏文章为《代码随想录》书籍的刷题题解以及读书笔记&#xff0c;如有侵权&#xff0c;立即删除。 一、题目 1、原题链接 242. 有效的字母异位词 2、题目描述 二、解题…

一文理清楚-Docker 容器如何工作

Docker 容器如何工作 集装箱什么是虚拟机&#xff1f;虚拟化如何运作&#xff1f;什么是容器&#xff1f;什么是 Docker&#xff1f;总结 五星上将麦克阿瑟曾经说过&#xff1a;在docker面前&#xff0c;虚拟机就是个弟弟 集装箱 《盒子&#xff1a;集装箱如何让世界变得更小&…

剑指offer——删除链表的节点

题目描述&#xff1a;给定单向链表的头指针和一个要删除的节点的值&#xff0c;定义一个函数删除该节点。返回删除后的链表的头节点。 数据范围&#xff1a; 0 <链表节点值 < 10000 0 <链表长度 < 10000 示例1&#xff1a; 输入&#xff1a;{2,5,1,9}&#xff…

1.28寒假集训

A: 解题思路&#xff1a; 移项就好v mv / (M - m) 下面是c代码&#xff1a; #include<iostream> using namespace std; int main() {int t;double M,m,v;cin >> t;while(t ! 0){cin >> M >> m >> v;printf("%.2lf\n",(m * v) / (M…

数据库之 基础概念、安装mysql、sql语句基础

数据库之 基础概念、安装mysql、sql语句基础 【一】存储数据的演变过程&#xff1a; 文件存储&#xff1a; 初始阶段随意存放数据到文件&#xff0c;格式任意。目录规范引入&#xff1a; 软件开发使用目录规范&#xff0c;限制数据位置&#xff0c;建立专门文件夹。本地数据存…

Linux报 “no route to host” 异常 ping: sendmsg: No route to host

公司有台服务器迁移机房后跟另一台服务器相互ping不通&#xff0c;但是两台服务器都能上网能ping其他机器&#xff0c;其他机器都能ping通这两台服务器。检查两台服务器没有防火墙规则拦截&#xff0c;交换机上也没检查到acl过滤。 下图是迁移机房的服务器ping截图 下图是nfs服…

分布式空间索引了解与扩展

目录 一、空间索引快速理解 &#xff08;一&#xff09;区域编码 &#xff08;二&#xff09;区域编码检索 &#xff08;三&#xff09;Geohash 编码 &#xff08;四&#xff09;RTree及其变体 二、业内方案选取 三、分布式空间索引架构 &#xff08;一&#xff09;PG数…

腾讯云幻兽帕鲁4核16G14M服务器性能测评和价格

腾讯云幻兽帕鲁服务器4核16G14M配置&#xff0c;14M公网带宽&#xff0c;限制2500GB月流量&#xff0c;系统盘为220GB SSD盘&#xff0c;优惠价格66元1个月&#xff0c;277元3个月&#xff0c;支持4到8个玩家畅玩&#xff0c;地域可选择上海/北京/成都/南京/广州&#xff0c;腾…

通讯录项目(终)

Start And Stick 上一期我们将通讯录的项目的基本功能已经实现&#xff0c;这一篇文章我们将对通讯录进行完善。 目录 Start And Stick 上期回顾&#xff1a; 上期必要代码&#xff1a; 数据打印&#xff1a; 代码讲解&#xff1a; 头部插入数据&#xff1a; 代码讲解&…

27.1K Star,优雅的JSON 数据可视化工具

Hi&#xff0c;骚年&#xff0c;我是大 G&#xff0c;公众号「GitHub指北」会推荐 GitHub 上有趣有用的项目&#xff0c;一分钟 get 一个优秀的开源项目&#xff0c;挖掘开源的价值&#xff0c;欢迎关注。 想自己之前做 APP 开发会访问后端数据&#xff0c;这个数据就是 JSON …

【网络基础】网络协议传输层UDP和TCP

UDP 解包和分用 解包&#xff08;解析数据包&#xff09; 捕获数据包&#xff1a;首先&#xff0c;接收端的网络栈捕获UDP数据包。检查目的端口&#xff1a;接收端检查数据包头部的目的端口&#xff0c;以确定哪个应用程序应该接收该数据包。验证校验和&#xff1a;接收端可能…

【排序5】基数排序:数字的组织与整理艺术

&#x1f3a1;基数排序 &#x1f38a;1、基本思想&#x1f38a;2、基本步骤&#x1f38a;3、代码示例&#x1f38a;4、特性总结 &#x1f38a;1、基本思想 基数排序&#xff08;Radix Sort&#xff09;是一种非比较排序算法&#xff0c;它根据数字的每一位来对元素进行排序。它…

2024年数学建模美赛C题(预测 Wordle)——思路、程序总结分享

1: 问题描述与要求 《纽约时报》要求您对本文件中的结果进行分析&#xff0c;以回答几个问题。 问题1&#xff1a;报告结果的数量每天都在变化。开发一个模型来解释这种变化&#xff0c;并使用您的模型为2023年3月1日报告的结果数量创建一个预测区间。这个词的任何属性是否会…

Java TemporalAdjusters 时间调节器

提供了非常多处理日期相关的函数&#xff1a; 使用示例&#xff1a; /*** JCccc* param args*/public static void main(String[] args) {DateTimeFormatter pattern DateTimeFormatter.ofPattern("yyyy-MM-dd");LocalDateTime now LocalDateTime.now();//获取当月…

web前端项目-实现录音功能【附源码】

录音功能 运行效果&#xff1a;本项目可实现录音软件的录音、存储、播放等功能 HTML源码&#xff1a; &#xff08;1&#xff09;index.html&#xff1a; <!DOCTYPE html> <html><head><meta http-equiv"Content-Type" content"text/h…

java日志框架总结(三 、Log4j日志框架)

一、简介 Log4j ( Logger For Java ) , Java 日志的记录包。 官方网站 。Log4j 是 Apache 的一个开源项目&#xff0c; 为Java提供了日志记录功能。能够让程序员非常方便的记录日志&#xff0c; 并且提供了多种适配方式&#xff0c;能满足各种需求。 使用Log4j 只需要导入一个…

【时序预测】2、prophet:Forecasting at Scale | Python 文档教程

文章目录 一、Quick Start二、饱和预测2.1 Forecasting Growth 预测增长2.2 Saturating Minimum 饱和最小值 三、Trend Changepoints 趋势变化点3.1 Automatic changepoint detection in Prophet 自动检测变化点3.2 Adjusting trend flexibility 调整趋势灵活性3.3 Specifying …

从零开始做题:逆向 ret2shellcode orw

1.题目信息 BUUCTF在线评测 下载orw时防病毒要关闭 2.题目分析 orw是open、read、write的简写。有时候binary会通过prctl、seccomp进行沙箱保护&#xff0c;并不能getshell。只能通过orw的方式拿到flag。 fdopen&#xff08;‘./flag’); # 打开flag文件&#xff0c;得到fd…

线程调度(Java Android)

关于作者&#xff1a;CSDN内容合伙人、技术专家&#xff0c; 从零开始做日活千万级APP。 专注于分享各领域原创系列文章 &#xff0c;擅长java后端、移动开发、商业变现、人工智能等&#xff0c;希望大家多多支持。 未经允许不得转载 目录 一、导读二、概览2.1、线程的属性 三、…

HTTP服务器基础认识(复习)

鉴于曾经写过相关文章&#xff0c;这里就不再详细介绍了&#xff0c;关于详细的介绍可以参考我之前的文章 HTTP协议初识中篇-CSDN博客 一个简单的设置套接字的过程&#xff0c;也当成是复习一下下了 代码 #include <iostream> #include <cstdio> #include <…