Sep 7, 2020

Java 线程

观看至： https://www.bilibili.com/video/BV1V4411p7EF?p=23

什么是任务、进程、线程

多任务表示一个人边吃饭边玩手机，看上去是同时进行，实际上这一秒在吃饭下一秒在玩手机，只是切换时间很短感觉不出来
说道进程就得提程序，程序运行会创建一个进程，里面包含一个主线程如main函数，还有其他语言自带的守护线程如Java的GC
线程不一定立即执行，它是由CPU调度的

线程的三种创建方式

Thread class 继承Thread类

不建议使用：避免OOP单继承局限性
创建一个Class继承Thread class并重写run()方法，启动线程使用.start()

package com.painso.study.thread.demo01;
// create thread way 1: extend Thread class, override run() method, call start enable thread
public class D1 extends Thread{
    @Override
    public void run(){
        // run() body
        for (int i = 0; i<20;i++){
            System.out.println("i'm run() body "+i);
        }
    }
    public static void main(String[] args) {
        // main() body
        D1 d1 = new D1();
        d1.start();
        for (int i = 0; i < 20; i++){
            System.out.println("i'm main() body "+i);
        }
    }
}

Runnable interface 实现Runnable接口

建议使用：避免单继承局限性，方便灵活，方便同一个对象被多个线程使用
创建一个Class实现Runnable接口并重写run()方法，启动线程使用new Thread(p).start()

package com.painso.study.thread.demo03;
// create thread way 2: implement Runnable interface, override run() method, call Thread(p).start()
public class D implements Runnable {
    @Override
    public void run() {
        System.out.println("i'm a thread implement Runnable interface");
    }
    public static void main(String[] args) {
        // create Runnable interface implement Object
        D d = new D();
        // create thread Object
        Thread thread = new Thread(d); // agent
        thread.start();
    }
}

Callable interface 实现Callable接口

初识并发问题

当多个线程操作同一个资源会导致线程不安全从而出现一些奇怪的问题

package com.painso.study.thread.demo04;	
// 多个线程同时操作同一个对象
// 买火车票的例子
public class D1 implements Runnable {
  // 票数
  private int ticketNums = 10;
  @Override
  public void run() {
      while (true) {
          if (ticketNums <= 0) {
              break;
          }
          // 模拟延时
          try {
              Thread.sleep(200);
          } catch (InterruptedException e) {
              e.printStackTrace();
          }
System.out.println(Thread.currentThread().getName() + "拿到了第" + ticketNums-- + "张票");
//            ticketNums--;
      }
  }
  public static void main(String[] args) {
      D1 ticket = new D1();
      new Thread(ticket, "小麦").start();
      new Thread(ticket, "小红").start();
      new Thread(ticket, "小明").start();
  }
}
/* output
小麦拿到了第10张票
小红拿到了第9张票
小明拿到了第8张票
小麦拿到了第7张票
小红拿到了第6张票
小明拿到了第5张票
小麦拿到了第4张票
小红拿到了第3张票
小明拿到了第2张票
小麦拿到了第1张票
小红拿到了第0张票
小明拿到了第-1张票
*/

要解决上述问题需要用到锁

案例：龟兔赛跑 rabbit tortoise race 即使跑的再慢也不能停止脚步

首先设置赛道距离，需要离终点越来越近
判断比赛是否结束
打印出胜利者
龟兔赛跑开始
设定兔子需要睡觉，需模拟兔子睡觉
乌龟赢得比赛

package com.painso.study.thread.demo05;
  
// 模拟龟兔赛跑
public class D implements Runnable {
  
    // 胜利者 胜利者只有一个这里用 static 关键字
    private static String winner;
    @Override
    public void run() {
        for (int i = 0; i <= 100; i++) {
            String role = Thread.currentThread().getName();
            // 判断比赛是否结束
            boolean flag = isGameOver(i);
            // 如果比赛结束则停止程序
            if (flag) {
                break;
            }
            // 模拟兔子休息
            if (role.equals("Rabbit") && i % 10 == 0) {
                try {
                    Thread.sleep(200);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            //  模拟乌龟速度
            if (role == "Tortoise") {
                try {
                    Thread.sleep(10);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            System.out.println(role + "离终点还有" + (100 - i) + "米");
        }
    }
    // 判断比赛是否完成
    private boolean isGameOver(int steps) {
        // 判断是否有胜利者
        if (winner != null) {
            return true;
        }
        // 判断是否有角色到达终点
        if (steps >= 100) {
            winner = Thread.currentThread().getName();
            System.out.println("winner is " + winner);
            return true;
        }
        return false;
    }
    public static void main(String[] args) {
        D race = new D();
        new Thread(race, "Rabbit").start();
        new Thread(race, "Tortoise").start();
    }
}

Callable 接口

1. 实现`Callable`接口，需要返回值类型
2. 重写`call`方法，需要抛出异常
3. 创建目标对象
4. 创建执行服务： `ExecutorService ser = Executors.newFixedThreadPool(1)`
5. 提交执行： `Future<Boolean> result1 = ser.submit(t1)`
6. 获取结果： `boolean result = result1.get()`
7. 关闭服务： `ser.shutdownNow()`

静态代理模式

真实对象和代理对象都要实现同一个接口
代理对象接受真实对象为参数

代理对象可以为真实对象做额外操作，而真实对象只需关注本身

package com.painso.study.thread.demo06;
public class ThreadProxy {
    public static void main(String[] args) {
        // 静态代理
        new WeddingCompany(new You()).Marry();
        // 类比实现了Runnable接口的对象
        new Thread(() -> System.out.println("aaa")).start();
    }
}
interface Marry {
    void Marry();
}
class You implements Marry {
    @Override
    public void Marry() {
        System.out.println("张三结婚了");
    }
}
class WeddingCompany implements Marry {
    private Marry role;
  
    public WeddingCompany(Marry role) {
  
        this.role = role;
    }
    private void before() {
        System.out.println("布置。。。。。。。");
    }
  
    private void after() {
        System.out.println("结帐。。。。。");
    }
    @Override
    public void Marry() {
        before();
        this.role.Marry();
        after();
  
    }
}

Lambda 表达式

Lambda，是第十一个希腊字母。大写Λ用于：粒子物理学上，Λ重子的符号宇宙学及物理学上，爱因斯坦宇宙学常量的符号数学上，三角形函数的符号小写λ用于：物理上的波长符号放射学的衰变常数线性代数中的特征值
避免匿名内部类定义过多
其实质属于函数式编程的概念

/*
(params) -> expression
(params) -> statement
(params) -> { statements }
a -> System.out.println("i like lambda-->"+a);
*/
package com.painso.study.thread.demo07;
  
public class Lambda {
    public static void main(String[] args) {
        new Thread(() -> System.out.println("i'm lambda, Thread name: " + Thread.currentThread().getName()),"WeaponX").start();
    }
}

函数式接口
- 任何接口如果只包含唯一一个抽象方法，那么它就是一个函数式接口。
```
public interface Runnable{
    public abstract void run();
}
```
- 对于函数式接口，我们可以通过Lambda表达式来创建该接口的对象。

多线程五大状态

线程的生命周期 lifecycle
- 方法说明setPriority(int newPriority)更改线程的优先级static void sleep(long millis)在指定的毫秒数内让当前正在执行的线程休眠void join()等待该线程终止static void yield()暂停当前正在执行的线程对象，并执行其他线程void interrupt()中断线程，不推荐使用boolean isAlive()检查线程是否处于活动状态
- - 不推荐使用JDK提供的stop()、destroy()方法已废弃
  - 推荐线程自己停止
  - 建议使用一个标志位进行终止变量 -> if flag==false则终止线程运行
- Sleep
每个对象都有一个锁，sleep不会释放锁。
线程礼让 Yield
- 礼让线程，让当前正在执行的线程暂停，但不阻塞
- 将线程从运行状态转为就绪状态
- **让CPU重新调度，Yield不一定成功，看CPU心情
  假设有A和B两个线程，启动主程序时CPU安排A先进入调度，但是A使用了Yield方法，从而回归最开始的就绪状态重新让CPU安排调度
- Join合并线程，待此线程执行完成后，再执行其他线程，此时其他线程处于阻塞状态
- 理解为线程之间插队

线程状态观测

Thread.State
线程状态可以处于以下状态之一
一个线程可以在给定的时间点处于一个状态。这些状态是不反映任何操作系统线程状态的虚拟机状态。
- 尚未启动的线程处于此状态
- RUNNABLE
  在Java虚拟机中执行的线程处于此状态
- BLOCKED
  被阻塞等待监视器锁定的线程处于此状态
- WAITING
  正在等待另一个线程执行特定动作的线程处于此状态
- TIMED_WAITING
  正在等待另一个线程执行动作达到指定等待时间的线程处于此状态
- TERMINATED
  已退出的线程处于此状态

线程的优先级

Java提供一个线程调度器来监控程序中启动后进入就绪状态的所有线程，线程调度器按照优先级决定应该调度哪个线程来执行。
线程的优先级用数字表示，范围从1～10
- Thread.MIN_PRIORITY = 1;
- Thread.MAX_PRIORITY = 10;
- Thread.NORM_PRIORITY = 5;
使用以下方式改变或获取优先级
- getPriority()
- setPriority(int x)

守护线程(daemon)

线程分为用户线程和守护线程
虚拟机必须确保用户线程执行完毕
虚拟机不用等待守护线程执行完毕
作用：后台记录操作日志，内存监控，垃圾回收等。

现实生活中，我们会遇到"同一个资源，多个人都想使用"的问题，比如食堂排队打饭，每个人都想吃饭，最天然的解决办法就是排队。
处理多线程问题时，多个线程访问同一个对象(并发)，并且某些线程还想修改这个对象，这时候我们就需要线程同步。线程同步其实就是一种等待机制，多个需要同时访问此对象的线程进入这个对象的等待池形成队列，等待前面的线程使用完毕，下一个线程再使用。
由于同一个进程的多个线程共享同一块存储空间，在带来方便的同时，也带来了访问冲突的问题，为了保证数据在方法中被访问时的正确性，在访问同时加入锁机制, synchronized，当一个线程获得对象的排它锁，独占资源，其他线程必须等待，使用后释放锁即可。存在以下问题
- 一个线程持有锁会导致其他所有需要此锁的线程挂起
- 在多线程竞争下，加锁、释放锁会导致比较多的上下文切换和调度延时，引起性能问题
- 如果一个优先级高的线程等待一个优先级低的线程释放锁会导致优先级倒置，引起性能问题

synchronized不论是方法还是代码块，应锁需要CRD(Create、Retrieve、Delete)的对象

由于我们可以通过private关键字来保证数据对象只能被访问方法，所以我们只需要针对方法提出一套机制，这套机制就是synchronized关键字，它包括两种方法
- synchronized方法
  public synchronized void method(int args){}
  方法里面需要修改的内容才需要锁，锁太多造成资源浪费
- synchronized块
  synchronized (Obj){}
  Obj称之为同步监视器
  - Obj可以是任何对象，但是推荐使用共享资源作为同步监视器
  - 同步方法中无需制定同步监视器，因为同步方法的同步监视器就是this，就是这个对象本身，或者是class
  同步监视器执行过程
  1. 第一个线程访问，锁定同步监视器，执行其中代码
  2. 第二个线程访问，发现同步监视器被锁定，无法访问
  3. 第一个线程访问完毕，解锁同步监视器
  4. 第二个线程访问，发现同步监视器没有锁，然后锁定并访问
synchronized方法控制对象的访问，每个对象对应一把锁，每个synchronized方法都必须获得调用该方法对象的锁才能执行，否则线程会阻塞，方法一旦执行，就独占该锁，知道方法返回才释放锁，后面被阻塞的线程才能获得这个锁继续执行。
若将一个大的方法声明为synchronized将会影响效率

死锁 `DeadLock`

死锁，又译为死结，计算机科学名词。当两个以上的运算单元，双方都在等待对方停止运行，以获取系统资源，但是没有一方提前退出时，就称为死锁。在多任务操作系统中，操作系统为了协调不同行程，能否获取系统资源时，为了让系统运作，必须要解决这个问题。这里指的是进程死锁，是个计算机技术名词。维基百科

多个线程各自占有一些共享资源，并且互相等待其他线程占有的资源才能运行，而导致两个或多个线程都在等待对方释放资源，都停止执行的情形。某一个同步块同时拥有两个以上对象的锁时，就可能发生"死锁"的问题

死锁的避免方法

产生死锁的四个必要条件
1. 互斥条件，一个资源每次只能被一个进程使用
2. 请求与保持条件，一个进程因请求资源而阻塞时，对已获得的资源保持不放
3. 不剥夺条件，进程已获得的资源，在未使用完之前，不能强行剥夺
4. 循环等待条件，若干进程之间形成一种头尾相接循环等待资源关系
上面列出了死锁的四个必要条件，只要想办法破其中的任意一个或多个条件就可以避免死锁发生

Java 线程

Java 线程

什么是任务、进程、线程

线程的三种创建方式

初识并发问题

Callable 接口

静态代理模式

Lambda 表达式

多线程五大状态

线程状态观测

线程的优先级

守护线程(daemon)

死锁 `DeadLock`

Recommend

DDIA · 数据编码与演化

无模型策略预测和控制 - 时序差分学习 (Model-Free Policy Prediction and Control -...

提升编写 Verilog 的体验

Google SRE 生存指南笔记

使用 systemd 管理 frpc 服务

MIPS 单周期处理器开发

国际智慧温室种植挑战赛 (International Autonomous Greenhouse Challenge)

Java ExcelUtil 库导出Excel表格报错问题

隐马尔可夫 (Hidden Markov Model, HMM)，条件随机场 (Conditional Random Fields, CR...

一个人的摩旅 (Travel with My Motorcycle Alone)

About Joyk

Java 线程

Java 线程

什么是任务、进程、线程

线程的三种创建方式

初识并发问题

Callable 接口

静态代理模式

Lambda 表达式

多线程五大状态

线程状态观测

线程的优先级

守护线程(daemon)

死锁 DeadLock

Recommend

About Joyk

死锁 `DeadLock`