多线程的创建

一、基本概念

1 cpu

CPU的中文名称是中央处理器,是进行逻辑运算用的,主要由运算器、控制器、寄存器三部分组成,从字面意思看就是运算就是起着运算的作用,控制器就是负责发出cpu每条指令所需要的信息,寄存器就是保存运算或者指令的一些临时文件,这样可以保证更高的速度。也就是我们的线程运行在cpu之上。

2 进程/线程

进程是资源分配最小单位,线程是程序执行的最小单位。 计算机在执行程序时,会为程序创建相应的进程,进行资源分配时,是以进程为单位进行相应的分配。每个进程都有相应的线程,在执行程序时,实际上是执行相应的一系列线程

  • 总结:进程是资源分配最小单位,线程是程序执行的最小单位

  • 什么是进程:

    1. cpu从硬盘中读取一段程序到内存中,该执行程序的实例就叫做进程

    2. 一个程序如果被cpu多次被读取到内存中,则变成多个独立的进程

  • 什么是线程:

    线程是程序执行的最小单位,在一个进程中可以有多个不同的线程同时执行。

3 多线程优点

采用多线程的形式执行代码,目的就是为了提高程序的效率。

比如:现在一个项目只有一个程序员开发,需要开发功能模块会员模块、支付模块、订单模块。

如果小军,小明,小薇的开发水平一样,一个人5天只能完成一个模块,那么一个人完成全部工作需要15天,3个人同时完成这些工作只需要5天。

4 并行/串行

串行也就是单线程执行 代码执行效率非常低,代码从上向下执行; (同步操作)

并行就是多个线程并行一起执行,效率比较高。 (异步操作)

并发指两个或多个事件在同一个时间段内发生。

5 CPU时间片

  1. 单核的cpu上每次只能够执行一次线程,如果在单核的cpu上开启了多线程,则会发生对每个线程轮流执行 。

  2. Cpu每次单个计算的时间成为一个cpu时间片,实际只有几十毫秒人为感觉好像是在多线程。

  3. 对于线程来说,存在等待cpu调度的时候 该线程的状态是为就绪状态,如果被cpu调度则该线程的状态为运行状态

  4. 当cpu转让执行其他的线程时,则该线程有变为就绪状态。

6 计算密集型/IO密集型

计算密集型:长时间占用cpu;例如: 视频剪辑

IO密集型 :cpu计算时间短 , 访问外接设备时间长Input/output

7 上下文切换

多线程编程中一般线程的个数都大于 CPU 核心的个数,而一个 CPU 核心在任意时刻只能被一个线程使用,为了让这些线程都能得到有效执行,CPU 采取的策略是为每个线程分配时间片并轮转的形式。当一个线程的时间片用完的时候,就会重新处于就绪状态让给其他线程使用,这个过程就属于一次上下文切换。

二、创建方式

创建方式:

  • 继承Thread类创建线程

  • 实现Runnable接口创建线程

  • 使用Callable和Future创建线程

  • 使用线程池例如用Executor框架

  • 使用匿名内部类的形式创建线程

  • 使用lambda表达式创建线程

1 继承Thread类创建线程

public class ThreadDemo01 extends Thread{@Overridepublic void run() {System.out.println(Thread.currentThread().getName()+"在运行");}public static void main(String[] args) {ThreadDemo01 demo01 = new ThreadDemo01();demo01.start();}
}

2 实现Runnable接口创建线程

public class ThreadDemo02 implements Runnable {@Overridepublic void run() {System.out.println(Thread.currentThread().getName() + ",我是子线程");}public static void main(String[] args) {new Thread(new ThreadDemo02()).start();}
}

3 使用Callable和Future创建线程

从Java 5开始,Java提供了Callable接口,该接口是Runnable接口的增强版,Callable接口提供了一个call()方法,可以看作是线程的执行体,但call()方法比run()方法更强大。

call()方法可以有返回值。

call()方法可以声明抛出异常。

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;public class ThreadCallable implements Callable<Integer> {@Overridepublic Integer call() throws Exception {System.out.println(Thread.currentThread().getName());return 1;}public static void main(String[] args) throws ExecutionException, InterruptedException {ThreadCallable callable = new ThreadCallable();FutureTask<Integer> futureTask = new FutureTask<Integer>(callable);new Thread(futureTask).start();Integer result = futureTask.get();System.out.println(result);}
}

4 使用线程池例如用Executor框架

public class ThreadDemo03{public static void main(String[] args) {ExecutorService service = Executors.newCachedThreadPool();//方法参数是Runnable的实现类service.execute(()->System.out.println(Thread.currentThread().getName() + ">我是子线程<"));}
}

5 使用匿名内部类的形式创建线程

public class ThreadDemo04 {public static void main(String[] args) {new Thread(new Runnable() {@Overridepublic void run() {System.out.println(Thread.currentThread().getName());}}).start();}
}

6 使用lambda表达式创建线程

public class ThreadDemo04 {public static void main(String[] args) {new Thread(()->System.out.println(Thread.currentThread().getName())).start();}
}

7 Thread和Runnable的区别

实现Runnable接口比继承Thread类所具有的优势:

  1. 适合多个相同的程序代码的线程去共享同一个资源。

  2. 可以避免java中的单继承的局限性。

  3. 增加程序的健壮性,实现解耦操作,代码可以被多个线程共享,代码和线程独立。

  4. 线程池只能放入实现Runable或Callable类线程,不能直接放入继承Thread的类。

 三、线程状态

 

1 新建

当用new关键字创建一个线程时,还没调用start 就是新建状态。

2 就绪

调用了 start 方法之后,线程就进入了就绪阶段。此时,线程不会立即执行run方法,需要等待获取CPU资源。

3 运行

当线程获得CPU时间片后,就会进入运行状态,开始执行run方法。

4 阻塞

当遇到以下几种情况,线程会从运行状态进入到阻塞状态。

  • 调用wait方法,jvm会将线程放入等待队列(waiting queue),使线程进入等待。

  • 当线程去获取同步锁的时候,锁正在被其他线程持有,jvm会将该线程放入锁池(lock pool)

  • 其他阻塞,运行状态的线程调用sleep方法、join方法,或者进入io请求的时候,会导致线程阻塞。

需要注意的是,阻塞状态只能进入就绪状态,不能直接进入运行状态。因为,从就绪状态到运行状态的切换是不受线程自己控制的,而是由线程调度器所决定。只有当线程获得了CPU时间片之后,才会进入运行状态。

5 死亡

当run方法正常执行结束时,或者由于某种原因抛出异常都会使线程进入死亡状态。另外,直接调用stop方法也会停止线程。但是,此方法已经被弃用,不推荐使用。

四、线程的基本方法

1 线程等待:wait方法

  • 调用wait()方法,线程会进入WATING状态,只有等到其他线程的通知活被中断后才会返回。需要注意的是,在调用wait()方法的后会释放对象的锁,因此wait()方法一般被用到同步方法或者同步代码块中。

2 线程睡眠:sleep方法

  • 用sleep方法会导致当前线程休眠。与 wait方法不同的是,sleep方法不会释放当前占有的锁,会导致线程进人 TIMED-WATING 状态,而 wait方法会导致当前线程进入WATING.

3 线程让步: yield 方法

调用yield 方法会使当前线程让出(释放)CPU执行时间片,与其他线程一起重新竞争CPU 时间片。在一般情况下,优先级高的线程更有可能竞争到CPU时间片,但这不是绝对的,有的操作系统对线程的优先级并不敏感。

4 线程中断:interrupt方法

  • interrupt方法用于向线程发行一个终止通知信号,会影响该线程内部的一个中断标识位,这个线程本身并不会因为调用了interrupt方法而改变状态(阻塞、终止等)。状态的具体变化需要等待接收到中断标识的程序的最终处理结果来判定。

5 线程加入 join方法

8 start方法和run方法的区别

  • join方法用于等待其他线程终止,如果在当前线程中调用一个线程的 join方法,则当前线程转为阻塞状态,等到另一个线程结束,当前线程再由阻塞状态转为就绪状态,等待获取CPU 的使用权。在很多情况下,主线程生成并启动了子线程,需要等到子线程返回结果并收集和处理再退出,这时就要用到join方法,具体的使用方法如下:

    System.out.println(”子线程运行开始!"):
    ChildThread childThread - new ChildThread();
    childThread.join(0);//等待子线程childThread执行结束
    System.out.println("子线join ()结束,开始运行主线程");

    6 线程唤醒: notify方法

    Object类有个 notify方法,用于唤醒在此对象监视器上等待的一个线程,如果所有线程都在此对象上等待,则会选择唤醒其中一个线程,选择是任意的我们通常调用其中一个对象的 wait方法在对象的监视器上等待 直到当前线程放弃此对象上的锁定,才能继续执行被唤醒的线程,被唤醒的线程将以常规方式与在该对象上主动同步的其他线程竞争。类似的方法还有notifyAll,用于唤醒在监视器上等待的所有线程。

    7 sleep方法与 wait方法的区别如下:

  • sleep方法属于Thread类,wait方法则属于Object类。

  • sleep方法暂停执行指定的时间,让出 CPU 给其他线程,但监控器状态依然保持在指定的时间过后又会自动恢复运行状态。

  • start方法用于启动线程,真正实现了多线程运行。在调用了线程的start方法后,线程会在后台执行,无须等待run方法体的代码执行完毕,就可以继续执行下面的代码。

  • 在通过调用 Thread 类的 start方法启动一个线程时,此线程处于就绪状态,并没有运行。

  • run方法也叫作线程体,包含了要执行的线程的逻辑代码,在调用run方法后,线程就进入运行状态,开始运行 run方法中的代码。在run方法运行结束后,该线程终止,CPU再调度其他线程

  • 在调用sleep方法的时候线程不会释放对象锁。

  • 在调用wait方法时,线程会放弃对象锁,进入等此对象的等待锁池,只有针对此对象调用notify方法后,该线程才能进人对象锁池准备获取对象锁,并进入运行状态。

 五、线程安全问题

1 问题出现的原因

如果有多个线程在同时运行,而这些线程可能会同时操作一个变量。程序每次运行结果和单线程运行的结果是一样

的,而且其他的变量的值也和预期的是一样的,就是线程安全的。

# 我们通过一个案例,演示线程的安全问题: 电影院要卖票,我们模拟电影院的卖票过程。假设要播放的电影是 “葫芦娃大战奥特曼”,本次电影的座位共100个 
(本场电影只能卖100张票)。 
我们来模拟电影院的售票窗口,实现多个窗口同时卖 “葫芦娃大战奥特曼”这场电影票(多个窗口一起卖这100张票) 
需要窗口,采用线程对象来模拟;需要票,Runnable接口子类来模拟
public class Ticket implements Runnable {private int ticket = 100;/** 执行卖票操作*/@Overridepublic void run() {//每个窗口卖票的操作//窗口 永远开启while (true) {if (ticket > 0) {//有票 可以卖//出票操作//使用sleep模拟一下出票时间try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}//获取当前线程对象的名字String name = Thread.currentThread().getName();System.out.println(name + "正在卖:" + ticket--);}}}
}
public class Demo01 {public static void main(String[] args) {Ticket ticket = new Ticket();Thread t1 = new Thread(ticket, "窗口1");Thread t2 = new Thread(ticket, "窗口2");t1.start();t2.start();}
}

 

可以看到同一张票被买了两次,这种问题,几个窗口(线程)票数不同步了,这种问题称为线程不安全。

线程安全问题都是由全局变量及静态变量引起的。若每个线程中对全局变量、静态变量只有读操作,而无写 操作,一般来说,这个全局变量是线程安全的;若有多个线程同时执行写操作,一般都需要考虑线程同步, 否则的话就可能影响线程安全。

2 如何解决问题

当我们使用多个线程访问同一资源的时候,且多个线程中对资源有写的操作,就容易出现线程安全问题。 要解决上述多线程并发访问一个资源的安全性问题:也就是解决重复票与不存在票问题,Java中提供了同步机制(synchronized)来解决。

窗口1线程进入操作的时候,窗口2线程只能在外等着,窗口1操作结束,窗口1和窗口2才有机会进入代码 去执行。也就是说在某个线程修改共享资源的时候,其他线程不能修改该资源,等待修改完毕同步之后,才能去抢夺CPU 资源,完成对应的操作,保证了数据的同步性,解决了线程不安全的现象。

3 解决方法

  • 同步代码块。

  • 同步方法。

  • 锁机制

 

 同步代码块

同步锁:

对象的同步锁只是一个概念,可以想象为在对象上标记了一个锁.

  • 锁对象 可以是任意类型。

  • 多个线程对象 要使用同一把锁。

注意:在任何时候,最多允许一个线程拥有同步锁,谁拿到锁就进入代码块,其他的线程只能在外等着(BLOCKED)。

synchronized 关键字可以用于方法中的某个区块中,表示只对这个区块的资源实行互斥访问。

格式:

synchronized(同步锁){需要同步操作的代码
}
public class Ticket implements Runnable {private int ticket = 100;Object lock = new Object();/** 执行卖票操作*/@Overridepublic void run() {//每个窗口卖票的操作//窗口 永远开启while (true) {synchronized (lock){if (ticket > 0) {//有票 可以卖//出票操作//使用sleep模拟一下出票时间try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}//获取当前线程对象的名字String name = Thread.currentThread().getName();System.out.println(name + "正在卖:" + ticket--);}}}}
}

当使用了同步代码块后,上述的线程的安全问题,解决了。

 

同步方法

同步方法:使用synchronized修饰的方法,就叫做同步方法,保证A线程执行该方法的时候,其他线程只能在方法外 等着。

同步锁是谁?

  • 对于非static方法,同步锁就是this。

  • 对于static方法,我们使用当前方法所在类的字节码对象(类名.class)。

格式:

public synchronized void method(){可能会产生线程安全问题的代码
}
public class Ticket implements Runnable {private int ticket = 100;@Overridepublic void run() {//每个窗口卖票的操作 ,窗口 永远开启while(true){sellTicket();}}/** 锁对象 是 谁调用这个方法 就是谁* 隐含 锁对象 就是 this**/public synchronized void sellTicket(){if(ticket>0){//有票 可以卖//出票操作//使用sleep模拟一下出票时间try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}//获取当前线程对象的名字String name = Thread.currentThread().getName();System.out.println(name+"正在卖:"+ticket--);}}
}

Lock锁

java.util.concurrent.locks.Lock 机制提供了比synchronized代码块和synchronized方法更广泛的锁定操作, 同步代码块/同步方法具有的功能Lock都有,除此之外更强大,更体现面向对象。

Lock锁也称同步锁,加锁与释放锁方法化了,如下:

  • public void lock() :加同步锁。

  • public void unlock() :释放同步锁。

语法格式

Lock lock = new ReentrantLock();
try{lock.lock();//加锁操作
}finally{lock.unlock();
}
public class Ticket implements Runnable {private int ticket = 100;Lock lock = new ReentrantLock();/** 执行卖票操作*/@Overridepublic void run() {//每个窗口卖票的操作永远开启while(true){lock.lock();if(ticket>0){//有票 可以卖//出票操作//使用sleep模拟一下出票时间try {Thread.sleep(50);} catch (InterruptedException e) {e.printStackTrace();}//获取当前线程对象的名字String name = Thread.currentThread().getName();System.out.println(name+"正在卖:"+ticket--);}lock.unlock();}}
}

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

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

双系统时间问题、虚拟机扩展空间问题

文献阅读计划&#xff1a; 首先要用ChatGPT查文献&#xff0c;用关键字查询&#xff0c;然后去搜索 add cyun 9.8 但是我发现好难搜啊&#xff0c;或者说相关的关键词搜不出来东西啊。不过师兄倒是搜的挺多的&#xff0c;这一点要再去好好学习一下 双系统时间问题&#xff1a…

LeetCode 50题:实现Pow(x,n)

题目 实现 pow(x, n) &#xff0c;即计算 x 的整数 n 次幂函数&#xff08;即&#xff0c;xn &#xff09;。 示例 1&#xff1a; 输入&#xff1a;x 2.00000, n 10 输出&#xff1a;1024.00000示例 2&#xff1a; 输入&#xff1a;x 2.10000, n 3 输出&#xff1a;9.26…

iPhone苹果手机来电收到消息闪光灯闪烁通知提醒功能怎么开启?

iPhone苹果手机来电收到消息闪光灯闪烁通知提醒功能怎么开启&#xff1f; 1、打开iPhone苹果手机上的「设置」&#xff1b; 2、在苹果iPhone手机设置内找到并点击打开「辅助功能」&#xff1b; 3、在苹果iPhone手机辅助功能内找到并点击打开「音频/视觉」&#xff1b; 4、在苹…

9月11日作业

思维导图 代码 #include <iostream> #include<string.h>using namespace std;class myString { private:char *str; //记录c风格的字符串int size; //记录字符串的实际长度 public://无参构造myString():size(10){str new char[size]; …

js中如何实现字符串去重?

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ 使用 Set 数据结构⭐ 使用循环遍历⭐ 写在最后 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门之旅&#xff01;这个专栏是为那些对Web开发感…

RJ45水晶头网线顺序出错排查

线序 网线水晶头RJ45常用的线序标准ANSI / TIA-568定义了T568A与T568B两种线序&#xff0c;一般使用T568B&#xff0c;水晶头8个孔对应的8条线颜色如下图&#xff1a; 那1至8的编号&#xff0c;是从水晶头哪一面为参考呢&#xff0c;如下图&#xff0c;是水晶头金手指一面&am…

基于51单片机+DS1302时钟模块+4位数码管显示

一、DS1302时钟模块简介 二、绘制Proteus 仿真电路图 三、编写51单片机代码 #include "DS1302.h"// 位定义 sbit DS1302_DATA P3^3; sbit SCLK P3^2; sbit RST P3^1;// 向DS1302写一个字节 void DS1302_Write_Byte(unsigned char addrOrData) {unsigned char i;f…

docker安装xxl-job连接数据库时显示无法连接问题

背景&#xff1a; 在项目中需要定时任务调度&#xff0c;需要在docker容器中安装xxl-job 遇到的问题 部署成功后&#xff0c;可以访问xxl-job登录界面&#xff0c;点登录没反应&#xff0c;但过一段时间就弹出数据库拒绝连接&#xff0c;说MyBatis连接用户失败 原因&#xf…

【AIGC专题】Stable Diffusion 从入门到企业级实战0601

一、前言 本章是《Stable Diffusion 从入门到企业级实战》系列的第六部分Prompt专题篇《Stable Diffusion Prompt 专题》第01节 《Stable Diffusion Prompt 通用画风操作实战》。本部分内容&#xff0c;位于整个Stable Diffusion生态体系的位置如下图黄色部分所示&#xff1a;…

C++ Day4

目录 仿照string类&#xff0c;完成myString 类 思维导图 仿照string类&#xff0c;完成myString 类 #include <iostream> #include<cstring>using namespace std;class myString {private:char *str; //记录c风格的字符串int size; //记录…

Mysql数据库之常用SQL语句及事务学习总结

数据库介绍 几个常见的缩写&#xff1a; DB&#xff1a;数据库。全称&#xff1a;DataBase。DBMS&#xff1a;数据库管理系统。全称&#xff1a;DataBase Management System。DBS&#xff1a;数据库系统。全称&#xff1a;DataBase System。DBA&#xff1a;数据库管理员。全称…

Mysql join用法详解

本篇文章旨在详细讲解Mysql 中join的用法&#xff0c;并附上例题。 一. left join 首先附上图 这个查询语句最根本的是要找出A表中所有的行&#xff0c; 所以如图所示&#xff0c;A表整个被涂蓝 A与B交叉的那部分可以视为ON后所跟的条件 重点是&#xff1a; 如果A表中有一条…

基于springboot2+mybatis-plus+jsp增删改查

概述 编写简单增删改查&#xff0c;理解之后可以自己试着扩展&#xff0c;相信你也可以&#xff0c;加油&#xff0c;我自己懂了的用注释记在下面方便理解 详细 一、需求&#xff08;要做什么&#xff09; 基于现今最流行的技术实现增删改查demo&#xff0c; 便于初学者上手…

[学习笔记]PageRank算法

参考资料&#xff1a;改变世界的谷歌PageRank算法 pagerank算法用于计算节点重要度 思想 如果网页被更多的入度(被引用)&#xff0c;则网页更重要。 被重要网站引用比被普通网站引用更加凸显重要性。 所以考虑一个网站是否重要&#xff0c;需要看引用它的网站是否重要&#…

从零开始搭建Apache服务器并使用内网穿透技术实现公网访问

Apache服务安装配置与结合内网穿透实现公网访问 文章目录 Apache服务安装配置与结合内网穿透实现公网访问前言1.Apache服务安装配置1.1 进入官网下载安装包1.2 Apache服务配置 2.安装cpolar内网穿透2.1 注册cpolar账号2.2 下载cpolar客户端 3. 获取远程桌面公网地址3.1 登录cpo…

Vue之scope属性

简介&#xff1a; 在使用Vue脚手架进行开发时&#xff0c;cli编译的时候本质上处理的是一个个文本文件&#xff0c;也就是字符串。每一个组件&#xff0c;即.Vue文件都是一个文本文件&#xff0c;里面包含着模板、组件对象实例以及style样式。组件化开发时&#xff0c;难免会出…

便捷查询中通快递,详细物流信息轻松获取

在如今快节奏的生活中&#xff0c;快递已成为人们生活中不可或缺的一部分。然而&#xff0c;快递查询却常常让人头疼&#xff0c;因为需要分别在不同的快递公司官网上进行查询&#xff0c;耗费时间和精力。为了解决这个问题&#xff0c;固乔科技推出了一款便捷的快递查询助手&a…

03深度学习-目标检测-深度学习方法与传统算法对比

一、目标学习的检测方法变迁及对比 “目标检测“是当前计算机视觉和机器学习领域的研究热点。从Viola-Jones Detector、DPM等冷兵器时代的智慧到当今RCNN、YOLO等深度学习土壤孕育下的GPU暴力美学&#xff0c;整个目标检测的发展可谓是计算机视觉领域的一部浓缩史。整个目标…

产品经理需要熟悉的网站

产品经理需要熟悉的网站 一、SAAS平台的聚合二、saas产品教程三、原型参考教程四、在线文档协作五、云笔记六、脑图&流程图 一、SAAS平台的聚合 作用&#xff1a;面试和工作的需要&#xff0c;方便各行业产品查找竞品。 网址&#xff1a;https://www.zhaosaas.com/&#x…

Spring Messaging远程命令执行漏洞复现(CVE-2018-1270)

一、漏洞说明 Spring Messaging为Spring框架提供消息支持&#xff0c;用户使用受影响版本的Spring Framework时&#xff0c;允许应用程序通过Spring Messaging模块内存中STOMP代理创建WebSocket。由于selector用SpEL表达式编写&#xff0c;并使用StandardEvaluationContext解析…