好友
阅读权限10
听众
最后登录1970-1-1
|
黑白客
发表于 2022-10-29 21:30
本帖最后由 黑白客 于 2022-10-29 21:33 编辑
[md]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:26 2021/2/22
* @Version: 1.0.0
* @Description: 下载器
*/
class WebDownloader{
//下载方法
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:26 2021/2/22
* @Version: 1.0.0
* @Description: 下载器
*/
class WebDownloader1 {
//下载方法
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()
> Thread a = 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状态,获得锁之后会继续运行。
![在这里插入图片描述]()[/md] |
免费评分
-
查看全部评分
|
发帖前要善用【论坛搜索】功能,那里可能会有你要找的答案或者已经有人发布过相同内容了,请勿重复发帖。 |
|
|
|
|