黑白客 发表于 2022-10-29 21:30

多线程的状态和实现方式,常用方法,中断方法

本帖最后由 黑白客 于 2022-10-29 21:33 编辑



java多线程的状态和实现方式,常用方法,中断方法
线程简介
java开启线程的方法有哪些
方法一` 继承Thread类`
第二种方法:`实现Runable接口,推荐使用 避免单线程的局限性。`
第三种方法: `创建线程的方法实现Callable接口`
中断线程的方法
等待线程运行自己运行完
interrupt 中断向量
stop方法
interrupt中断线程
多线程操作时,常用到的方法
Thread.sleep(500)
Thread.yield()
Thread.join()
线程的几个状态
new
ready
Runnig
teminated

## 线程简介
> 程序和进程和线程的关系
>
` 一个程序可以有多个进程,一个进程可以有多个线程`

> 进程和线程的区别

`进程是系统分配内存的最小单位,线程是程序执行的最小单位`

> 为什么有了进程还要有线程

`最开始的程序都是单线程的,有了线程的概念,主要是为了提高效率。
进程作为分配资源的最小单元,但是在对这块资源操作的时候可能会遇到io,阻塞等等,如果是单线程就需要去等待,但是多线程的情况下 我们就可以并行运行。`


- 核心概念
- 程序是静态的,一个程序跑起来之后就会变成一个进程,一个进程里可以有多个线程。main方法是主线程
- 线程就是独立的执行路径
- 在程序运行时,即使自己没有创建线程,后台也会有多个线程,如:主线程,gc线程(垃圾回收机制)
- main方法为主线程,为系统的入口,用于执行整个程序。
- 在一个进程中,如果开辟了多个线程,线程的运行由调度器安排调度。调度器是与电脑操作系统紧密相关的,先后顺序是不能人为干预的。
- 对同一份资源操作时,会存在资源抢夺的问题,需要加入并发控制。
- 线程会带来额外的开销,如cpu调度时间,并发控制开销。
- 每个线程在自己工作内存交互,内存控制不当会造成数据不一致



## java开启线程的方法有哪些
### 方法一` 继承Thread类`
- 创建一个类,继承Thread类。实现其run()方法、run方法就是线程体
- 在main方法中创建类的对象,调用start()方法。实现多线程。如果调用run方法,就不会实现多线程。是单线程。
- 线程创建之后并不会立即执行,需要cpu的调度安排。cpu在同一时间只能调用一个线程。
网图下载:利用多线程,下载多个网图
```java
package com.wang.threadDemo;

import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;
import java.net.URL;

/**
* @author: 王海新
* @Date: 2021/2/22 11:24
* @Description:下载网图
*/
public class TestThread2 extends Thread {
    private String url;
    private String name;

    TestThread2(String url,String name){
      this.url = url;
      this.name = name;
    }
    @Override
    public void run() {
      WebDownloader webDownloader = new WebDownloader();
      webDownloader.download(url,name);
      System.out.println("文件被下载了" + name);
    }
    public static void main(String[] args) {
      TestThread2 test1 = new TestThread2("https://ss1.baidu.com/9vo3dSag_xI4khGko9WTAnF6hhy/zhidao/pic/item/cdbf6c81800a19d86524639732fa828ba61e4679.jpg", "1.jpg");
      TestThread2 test2 = new TestThread2("https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fimg.08087.cc%2Fuploads%2F20191221%2F19%2F1576927577-ezdtLhXcng.jpg&refer=http%3A%2F%2Fimg.08087.cc&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1616557755&t=9c5d0cdc0fd6d2988b9522d0dab2f9c7", "2.jpg");
      TestThread2 test3 = new TestThread2("https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fimg.08087.cc%2Fuploads%2F20190819%2F10%2F1566182328-nwMPsxzGXL.jpg&refer=http%3A%2F%2Fimg.08087.cc&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1616557823&t=e0da3b689853d27b1a26d2879faec7eb", "3.jpg");

      test1.start();
      test2.start();
      test3.start();

    }
}

/*********************************************************************************************************************
* @Author:王海新
* @Date:11:262021/2/22
* @Version:1.0.0
* @Description:下载器
*/
classWebDownloader{
    //下载方法
    public void download(String url,String name){
      try {
            FileUtils.copyURLToFile(new URL(url),new File(name));
      } catch (IOException e) {
            System.out.println("io出错,出错方法:WebDownload");
      }
    }
}
```

### 第二种方法:`实现Runable接口,推荐使用 避免单线程的局限性。`

```java
package com.wang.threadDemo;

import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;
import java.net.URL;

/**
* @author: 王海新
* @Date: 2021/2/22 16:36
* @Description: 实现Runnable接口
*
*/
public class TestThread3 implements Runnable {
    private String url;
    private String name;

    TestThread3(String url,String name){
      this.url = url;
      this.name = name;
    }
    @Override
    public void run() {
      WebDownloader1 webDownloader = new WebDownloader1();
      webDownloader.download1(url,name);
      System.out.println("文件被下载了" + name);
    }
    public static void main(String[] args) {



      TestThread3 test1 = new TestThread3(
                "https://ss1.baidu.com/9vo3dSag_xI4khGko9WTAnF6hhy/zhidao/pic/item/cdbf6c81800a19d86524639732fa828ba61e4679.jpg", "4.jpg");
      TestThread3 test2 = new TestThread3(
                "https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fimg.08087.cc%2Fuploads%2F20191221%2F19%2F1576927577-ezdtLhXcng.jpg&refer=http%3A%2F%2Fimg.08087.cc&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1616557755&t=9c5d0cdc0fd6d2988b9522d0dab2f9c7", "5.jpg");
      TestThread3 test3 = new TestThread3(
                "https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fimg.08087.cc%2Fuploads%2F20190819%2F10%2F1566182328-nwMPsxzGXL.jpg&refer=http%3A%2F%2Fimg.08087.cc&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1616557823&t=e0da3b689853d27b1a26d2879faec7eb", "6.jpg");

      new Thread(test1).start();
      new Thread(test2).start();
      new Thread(test3).start();

    }
}

/*********************************************************************************************************************
* @Author:王海新
* @Date:11:262021/2/22
* @Version:1.0.0
* @Description:下载器
*/
classWebDownloader1 {
    //下载方法
    public void download1(String url, String name) {

      try {
            FileUtils.copyURLToFile(new URL(url), new File(name));
      } catch (IOException e) {
            e.printStackTrace();
            System.out.println("io出错,出错方法:WebDownload1");
      }
    }
}
```

基本上和继承Thread类相同,只是在调用的时候。

new 实现类

new Thread(实现类名).start();来调用
### 第三种方法: `创建线程的方法实现Callable接口`

## 中断线程的方法
### 等待线程运行自己运行完
> 最简单安全的一种方式。
### interrupt 中断向量
> 使用interrupt中断向量时,线程并不会直接停止,当发送给正在执行任务的线程时,正在执行的线程会抛出异常,一般我们通过try catch 捕获异常,然后处理。 一般可以用来中断一个正在TimeWating的线程。一般在程序调用中很少使用,在jdk中有对interrup较完善的使用,但是一般在工程中很少见到,也不优雅
### stop方法
> 通过java中的stop方法结束,但是容易造成数据的不一致等问题`
### interrupt中断线程
## 多线程操作时,常用到的方法
### Thread.sleep(500)
> sleeep 抱着锁睡觉,这个方法,会让我们的线程放弃cpu,休眠指定的时间,也就是不会放弃锁啦。
### Thread.yield()
>yield 让线程放弃一下cpu,进入到准备状态,当然,可能该线程放弃后,又立刻抢到了cpu执行。平时开发中很少有,需要线程必须释放一下cpu的场景,可能在测试,压力测试的时候会用到
>
### Thread.join()
> Threada = new Thread()
> 在线程b中调用 a.join。可以让b放弃cpu去执行a。等到a执行完成再回来执行b。
>
## 线程的几个状态
> 如图,可以脑子里想这个图,走一遍,不用死记下面的概念
### new
> new : 当new Thread的使用,这个时候还没有执行,时new状态。
### ready
> ready: 当调用 start() 方法时,就进入了就绪(ready)状态。
### Runnig
> Running : 当线程被cpu执行,就进入了Running状态。
### teminated
> teminated:执行完成,就终止退出,进入了teminated状态。

> 另外三种阻塞的状态
> TimeWaiting: 当调用sleep(time), wait(time),join(time)等方法时,会进入阻塞,等事件结束就会继续运行。
>
> Waiting: 调用wait(), join()等方式时,会进入阻塞,只有被notify()选中或者是其它线程执行了notifyAll() 时候,被cpu选中才可以继续执行。
> Blocked:当线程遇到锁时,且已经有其它线程在执行,需要等待时,这回进入Blocked状态,获得锁之后会继续运行。

![在这里插入图片描述](https://img-blog.csdnimg.cn/b671e75a13be4e8ca57872a6d63fb725.png)

江南云 发表于 2022-10-29 21:44

一下子分享这么多代码,慢慢来学学习一下。分享辛苦了!

jone33 发表于 2022-10-29 22:16

Copy的也不错

qiannideyoushou 发表于 2022-10-29 22:19

来学习学习!!

zjs3.13 发表于 2022-10-29 22:21

学习学习

sknbs 发表于 2022-10-30 00:47

学习了,还可以结合操作系统线程、进程状态设计讲解会更好

727426900 发表于 2022-10-30 09:46

学习学习

bj9ye666 发表于 2022-10-30 09:54

科普类好文章学习了感谢

xiadongming 发表于 2022-10-30 10:22

8970665 发表于 2022-10-30 12:00

系统重装了正需要
页: [1] 2
查看完整版本: 多线程的状态和实现方式,常用方法,中断方法