Java并发

目录

线程

什么是线程

进程和线程的区别

线程的生命周期

什么是多线程

并发与并行

多线程的三种实现方式

继承Thread类

1.创建类继承Thread类

2.重写run()方法

3.创建对象启动线程

实现Runnable接口

1.自己定义一个类实现Runnable接口

2.重写run方法

3.创建自己类的对象

4.创建一个Thread类的对象,并开启线程

实现Callable接口与FutureTask类

1.实现Callable接口

2.重写call方法并return线程执行的结果

3.创建Callable对象

4.把Callable对象封装成FutureTask对象

5.把任务交给Thread类

6.获取执行的结果

Thread常用方法

Thread常用构造器 

为什么启动线程要调用start()方法而不是直接调run()方法

线程安全

线程同步

思想

常见方案

同步代码块

作用

原理

锁对象的使用规范

同步方法

作用

底层原理

Lock锁

线程通信

什么是线程通信

生产者与消费者模型

等待和唤醒方法

线程池

什么是线程池

不使用线程池的问题

线程池组成

线程池参数

线程池执行任务的流程

临时线程什么时候创建

什么时候会拒绝新任务 


线程

什么是线程

线程是操作系统能够进行运算调度的最小单位,它被包含在进程之中,是进程中的实际运作单位。

 进程:进程是程序执行的基本实体。

拿任务管理器来举例, 我们可以看到其中的Edge、火绒等等这些应用程序我们就可以理解为他们是电脑里面的一个个进程。而在Edge中有九个就是在Edge这个进程里面对应的线程。

进程和线程的区别

根本区别:进程是操作系统资源分配的基本单位,而线程是处理器任务调度和执行的基本单位

资源开销:每个进程都有独立的代码和数据空间(程序上下文),程序之间的切换会有较大的开销;线程可以看做轻量级的进程,同一类线程共享代码和数据空间,每个线程都有自己独立的运行栈和程序计数器(PC),线程之间切换的开销小。

包含关系:如果一个进程内有多个线程,则执行过程不是一条线的,而是多条线(线程)共同完成的;线程是进程的一部分,所以线程也被称为轻权进程或者轻量级进程。

内存分配:同一进程的线程共享本进程的地址空间和资源,而进程之间的地址空间和资源是相互独立的

影响关系:一个进程崩溃后,在保护模式下不会对其他进程产生影响,但是一个线程崩溃整个进程都死掉。所以多进程要比多线程健壮。

执行过程:每个独立的进程有程序运行的入口. 顺序执行序列和程序出口。但是线程不能独立执行,必须依存在应用程序中,由应用程序提供多个线程执行控制,两者均可并发执行。

线程的生命周期

一个线程大致上有六种状态。

New新建:new Thread()出来的就是新建状态。

Runnable可运行:新建线程调用start方法。

Teminated被终止:线程执行完毕或者异常进入终止状态。

Blocked锁阻塞:当线程没有得到锁的时候便会进入锁阻塞状态,比如说a线程再访问一个需要锁的资源时,b线程也来访问,由于无法获得锁,便会进入锁阻塞状态,等到a线程释放锁之后b线程拿到锁便会回到Runnable可运行状态。

Waiting无限等待:当a线程对象使用wait()方法之后,会进入无限等待状态,只有其他线程比如b线程使用notify()唤醒了a线程如果a线程没有锁进入锁阻塞状态,如果有锁回到Runnable状态。

Timed Waiting计时等待:当线程从Runnable状态调用sleep(毫秒)或者wait(毫秒)之后会进入计时等待,时间结束之后。

回到Runnable:

  1. sleep时间到。  ps:sleep状态不会释放锁,而wait状态会释放锁。
  2. wait时间到并得到锁对象。
  3. wait时间没到,被其他线程notify并得到锁对象

进入Blocked:

wait时间到或者被notify未获得锁对象。

什么是多线程

在一个进程中同时执行多个线程的编程模型。线程是程序执行的最小单元,多线程编程允许程序在同一进程中的多个线程中并发执行,从而实现并行处理和提高系统的性能。

在多线程编程中,多个线程可以在同一时间片内交替执行,每个线程都有自己的执行路径和执行状态。不同于单线程程序只能按照顺序一步一步地执行,多线程程序可以同时执行多个任务,从而提高了并发性和响应性。

并发与并行

并发:在同一时刻,有多个指令在单个cpu上交替执行。

并行:在同一时刻,有多个指令在多个cpu上同时执行。

多线程的三种实现方式

继承Thread类

1.创建类继承Thread类
2.重写run()方法
package JUCDemo.demo1;
public class myThread extends Thread{@Overridepublic void run() {for (int i = 0;i < 10;i ++){System.out.println(getName() + "Hello Thread");}}
}
3.创建对象启动线程
package JUCDemo.demo1;
public class demo1 {public static void main(String[] args) {/*1.定义一个类继承Thread类2.重写Run方法3.创建子类对象并启动线程*/myThread t1 = new myThread();myThread t2 = new myThread();myThread t3 = new myThread();t1.setName("t1");t2.setName("t2");t3.setName("t3");t1.start();t2.start();t3.start();}
}

优点:编写简单,如果需要访问当前线程,则无需使用Thread.currentThread()方法,直接使用this即可获得当前线程。

缺点:线程类已经继承了Thread类,所以不能再继承其他父类。

实现Runnable接口

1.自己定义一个类实现Runnable接口
2.重写run方法
package JUCDemo.demo2;
public class myRunnable implements Runnable{@Overridepublic void run() {//获取当前线程的对象Thread t = Thread.currentThread();for (int i = 0; i < 10; i++) {System.out.println(t.getName()+"线程执行");}}
}

3.创建自己类的对象
4.创建一个Thread类的对象,并开启线程
package JUCDemo.demo2;
public class demo2 {public static void main(String[] args) {myRunnable myRunnable = new myRunnable();Thread t1 = new Thread(myRunnable);Thread t2 = new Thread(myRunnable);t1.setName("t1");t2.setName("t2");t1.start();t2.start();}
}

优点:没有继承Thread类,所以可以继承其他的类,适合多线程访问同一资源的情况,将cpu和数据分开,形成清晰的模型,较好的体现了面向对象的思想

缺点:编程相对复杂,要想获得当前线程对象,需要使用Thread.currentThread()方法。

实现Callable接口与FutureTask类

1.实现Callable接口

其中我们要制定返回的参数值类型,这里使用String。

2.重写call方法并return线程执行的结果
package JUCDemo.demo3;
import java.util.concurrent.Callable;
//1.实现Callable接口
public class myCallable implements Callable<String> {int n = 0;public myCallable(int n) {this.n = n;}//2.重写Call方法@Overridepublic String call() throws Exception {int sum = 0;for (int i = 0; i < n; i++) {sum = sum + i;}return "线程执行1到" + n + "的和是:" + sum;}
}
3.创建Callable对象
4.把Callable对象封装成FutureTask对象

FutureTask

由于Callable对象是无法扔给Thread的,所以我们要通过封装成FutureTask对象的形式把我们的Callable对象交给Thread。

我们通过FutureTask的源码可以发现,他是实现了Runnable接口的。

5.把任务交给Thread类
6.获取执行的结果
package JUCDemo.demo3;import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;public class demo {public static void main(String[] args) throws ExecutionException, InterruptedException {//3.创建Callable对象Callable<String> callable = new myCallable(100);//4.把Callable对象封装成一个FutureTask对象(任务对象)//FutureTask的作用//    是一个任务对象,实现了Runnable接口//    可以在任务结束之后,调用get方法获取执行完毕的结果FutureTask<String> f1 = new FutureTask<>(callable);//5.把任务对象交给Thread对象new Thread(f1).start();//6.获取线程执行完毕的结果String rs = f1.get();System.out.println(rs);}
}

优点

线程任务类只是实现接口,可以继续继承类和实现接口,扩展性强。可以在线程执行完毕后去获得线程执行完毕的结果。

缺点

编码复杂。

Thread常用方法

Thread提供常用方法说明
pulic void run()线程的任务方法
public void start()启动线程
public String getName()获取当前线程的名称,默认是Thread-索引
public void setName(String name)为线程设置名字
public static Thread currentThread()获取当前执行的线程对象
public static void sleep(long time)让线程休眠
public final void join()调用当前这个方法让线程先执行完

Thread常用构造器 

Thread常用构造器说明
public Thread(String name)可以为当前线程指定名称
public Thread(Runnable target)封装Runnable对象为线程对象
public Thread (Runnable target,String name)封装Runnable对象为线程对象,指定名称

为什么启动线程要调用start()方法而不是直接调run()方法

  • new 一个 Thread,线程进入了新建状态; 调用start() 会执行线程的相应准备工作,然后自动执行 run() 方法的内容,(调用 start() 方法,会启动一个线程并使线程进入了就绪状态,当分配到时间片后就可以开始运行了。)这是真正的多线程工作。
  • 直接执行 run() 方法,会把 run 方法当成一个 main 线程下的普通方法去执行,并不会在某个线程中执行它,所以这并不是多线程工作。 调用 start 方法方可启动线程并使线程进入就绪状态,而 run 方法只是 thread 的一个普通方法调用,还是在主线程里执行。

线程安全

Java线程安全问题是指在多线程环境下,多个线程同时访问共享资源时可能导致的数据不一致、数据损坏或程序异常等问题。这种问题可能发生在并发读写共享变量、共享数据结构或共享资源的情况下。

举个栗子,小明和小红共有一个银行账户,里面有100块钱。

当小明和小红都执行取钱操作的时候,系统会创建两个线程分别给小明和小红。

取钱分为两步,第一步判断余额,第二步账号减少余额并取出100。

当小明的线程判断完余额=100但是没有执行减少余额这个步骤时,小红线程进行了余额判断,那么系统便会分别给小明和小红100,这就是线程安全问题。

解决线程安全一般有三个方法,分别是:

线程同步

思想

让多个线程实现先后依次访问共享资源,这样就解决了线程安全问题。

常见方案

加锁:每次只允许一个线程加锁,加锁之后才能访问共享资源,访问完毕之后释放锁,然后其他线程才能再进行加锁操作并访问共享资源。

即,小明这个线程进入判断余额操作之后,会对判断余额上一把锁,上锁时小红线程就无法进行判断余额操作进入等待状态,只有当小明取钱完毕后小红才能进行余额判断。

同步代码块

作用

使用synchronized关键字把共享资源的核心代码块上锁,以保证此线程的安全。

原理

每次只允许一个线程加锁后进入,执行完毕后自动解锁,其他线程才可以进来执行。 

锁对象的使用规范

  • 建议使用共享资源作为锁对象,对于实例方法建议this作为锁对象。
  • 对于静态方法建议使用字节码(类名.class)对象作为锁对象。

同步方法

作用

使用synchronized关键字把共享资源的核心方法上锁,以保证此线程的安全。

底层原理

  • 同步方法也是有隐藏式锁对象的,只是锁的范围是整个方法代码
  • 如果方法时实例方法:同步方法默认this作为锁对象。
  • 如果方法时静态方法:同步方法默认类名.class作为锁的对象。  

Lock锁

  • Lock锁时jdk5开始提供的一个新的锁定操作,通过它可以创建出锁对象来进行加锁和解锁,更灵活、更强大、更方便。
  • Lock是接口,不能直接实例化,需要使用它的实现类ReentrantLock来构建Lock锁对象。

线程通信

什么是线程通信

当多个线程共同操作共享的资源时,线程之间通过某种方式互相告知自己的状态,以相互协调,避免无效的资源争夺。

生产者与消费者模型

生产者线程负责生产数据。

消费者线程负责消费生产者线程生产的数据。

生产者生产完数据应该等待自己,通知消费者消费。消费者消费完数据也应该等待自己,再通知生产者生产。

等待和唤醒方法

方法名称说明
void wait()让当前线程等待并释放所占锁,知道另一个线程调用notify方法或notifyAll方法
void notify()唤醒正在等待的单个线程
void notifyAll()唤醒所有正在等待的线程

线程池

什么是线程池

线程池就是一个可以复用线程的技术

不使用线程池的问题

用户每发起一个请求,后台就要创建一个新线程来处理,下次新任务来了肯定又要创建新的线程来处理,而创建新的线程的开销是很大的,并且请求过多时,肯定会产生大量线程出来,这样会严重影响系统的性能。

线程池组成

线程池管理器(ThreadPoolExecutor):线程池管理器是线程池的核心组件,负责创建、管理和调度线程。
工作线程(WorkQueue):工作队列用于存储等待执行的任务。当有新的任务提交给线程池时,线程池将任务放入工作队列中,并由线程池中的线程按照一定的策略从队列中取出任务进行执行。
线程池线程(Worker Thread):线程池中的线程是执行任务的工作单元。任务队列中的线程对象必须是实现了Runnable接口或者Callable接口的才能进入任务对列。

线程池参数

  1. 参数一:corePoolSize:指定线程池的核心线程数量。
  2. 参数二:maxmumPollSize:指定线程池的最大线程数量。
  3. 参数三:keepAliveTime:指定临时线程存活时间。
  4. 参数四:unit:指定临时线程的存活时间单位。
  5. 参数五:workQueue:指定线程池的任务对列。
  6. 参数六:threadFactory:指定线程池的线程工厂。
  7. 参数七:handler:指定线程池的任务拒绝策略。

可以理解成一个公司,corePoolSize就是正式工数量,maxmumPollSize就是最大员工数量正式工+临时工,keepAliveTime是临时工多长时间后会被辞退,workQueue客人排队的地方。

线程池执行任务的流程

临时线程什么时候创建

核心线程在忙而且任务队列也满了。

什么时候会拒绝新任务 

核心线程和临时线程都在忙,任务队列也满了。

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

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

相关文章

程序猿成长之路之番外篇——矩阵算法

今天在复习线性代数知识的过程中&#xff0c;用java语言简单实现了一下矩阵算法。 数学知识回顾 1.什么是矩阵 在数学领域&#xff0c;矩阵就像一个表格&#xff0c;将数据排放进去&#xff0c;形成一个矩形。我们习惯用一个大括号把矩阵内的数据包括进来。 1.矩阵 在数学领域…

FeignClient是否可以配置多个拦截器?

1、做法 在Spring Cloud中&#xff0c;FeignClient是一个声明式的Web服务客户端&#xff0c;让调用远程服务就像调用本地方法一样简单。拦截器可以用于在发送请求之前或者获得响应之后执行一些操作&#xff0c;比如添加公共的Header、记录日志、做一些统计等。 在Feign中&…

Python Web开发记录 Day14:Django part8 订单管理

名人说:莫道桑榆晚,为霞尚满天。——刘禹锡(刘梦得,诗豪) 创作者:Code_流苏(CSDN)(一个喜欢古诗词和编程的Coder😊) 目录 1、数据库准备2、添加订单3、订单列表4、删除订单5、编辑订单6、补充解答1、数据库准备 1.修改models.py,添加Order订单表 models.py class O…

JavaScript parseInt() 函数

JavaScript parseInt() 函数 从官方理解&#xff1a; parseInt() 函数解析字符串并返回整数。 radix 参数用于指定使用哪种数字系统&#xff0c;例如基数为 16&#xff08;十六进制&#xff09;表示字符串中的数字应从十六进制数解析为十进制数。 如果 radix 参数被省略&…

【HTML面试题】src和href的区别

一、请求资源不同 src 在请求资源时&#xff0c;会把这个资源下载下来href 建立链接通道&#xff0c;也就是引用元素和当前文档建立链接 二、作用结果不同 src 会替换当前元素href 只是引用资源和当前元素建立链接&#xff0c;所以不会替换当前内容。 三、浏览器解析方式不…

3.21作业

#include<myhead.h> int do_add(sqlite3 *ppDb) { int xue0; char name[20]""; double coure0; char sql[128]""; printf("请输入学号\n"); scanf("%d",&xue); printf("请输入姓名\n&qu…

Java SE

java概述 1.什么是java java是一门面向对象的编程语言&#xff0c;作为静态面向对象编程语言&#xff0c;极好地实现了面向对象理论&#xff0c;允许程序员以优雅的思维方式进行复杂的编程 。 2.java语言有哪些特点&#xff1f; 2.1面向对象&#xff08;继承封装多多态&…

SOCKS5是什么?

SOCKS5是什么&#xff1f; SOCKS5&#xff0c;作为SOCKS网络协议家族的最新版本&#xff0c;是一种高级的网络协议&#xff0c;用于在客户端和服务器之间通过一个代理服务器交换网络包。它的设计考虑了多种网络环境&#xff0c;包括对IPv6和UDP协议的支持&#xff0c;并引入了…

Uscrapper:一款功能强大的网络资源爬取工具

关于Uscrapper Uscrapper是一款功能强大的网络资源爬取工具&#xff0c;该工具可以帮助广大研究人员从各种网络资源中轻松高效地提取出有价值的数据&#xff0c;并且提供了稳定、友好且易于使用的UI界面&#xff0c;是安全研究人员和网络分析人员的强有力工具。 Uscrapper最大…

漫谈5种注册中心

01 注册中心基本概念 1.1 什么是注册中心&#xff1f; 注册中心主要有三种角色&#xff1a; 服务提供者&#xff08;RPC Server&#xff09;&#xff1a;在启动时&#xff0c;向 Registry 注册自身服务&#xff0c;并向 Registry 定期发送心跳汇报存活状态。 服务消费者&…

哈希、散列表和Rabin-Karp算法

字典 现有一个抽象数据类型(ADT)如下&#xff1a; 包括了一组元素&#xff0c;每个元素都有一个键key。假设没有元素拥有相同的key&#xff0c;如果有相同的key&#xff0c;则覆盖掉原有key的元素。 -insert(item) -delete(item) -search(key):根据给定的key&#xff0c;返…

JetBrains全家桶激活,分享 GoLand 2024 激活的方案

大家好&#xff0c;欢迎来到金榜探云手&#xff01; GoLand 公司简介 JetBrains 是一家专注于开发工具的软件公司&#xff0c;总部位于捷克。他们以提供强大的集成开发环境&#xff08;IDE&#xff09;而闻名&#xff0c;如 IntelliJ IDEA、PyCharm、和 GoLand等。这些工具被…

第4周 Python程序流程控制刷题(循环结构)

单击题目&#xff0c;直接跳转到页面刷题&#xff0c;一周后公布答案。 P5722&#xff1a;数列求和B2054&#xff1a;求平均年龄B2059&#xff1a;奇数求和B2064&#xff1a;斐波那契数列B2077&#xff1a;角谷猜想B2098&#xff1a;整数去重B2128&#xff1a;素数个数 1. P5…

力扣每日练习(3.20)补

322. 零钱兑换 想象你有一堆不同面值的硬币&#xff0c;现在的任务是用这些硬币凑出一个指定的金额&#xff0c;比如说11元&#xff0c;而且要求用的硬币数量尽可能少。 准备工作&#xff1a;首先&#xff0c;我们做了一张表&#xff08;叫dp&#xff09;&#xff0c;这张表记…

前端开发的第三方库

base64.js 地址&#xff1a;https://github.com/dankogai/js-base64 Base64.js 库提供了一个简单的 API&#xff0c;用于将数据转换为 Base64 编码&#xff0c;以及将 Base64 编码的数据解码回原始数据 Base64.js 是一个 JavaScript 库&#xff0c;用于将数据转换为 Base64 编…

LVGL:拓展部件——键盘 lv_keyboard

一、概述 此控件特点&#xff1a; 特殊Button矩阵&#xff1a;lv_keyboard 本质上是一个经过定制的按钮矩阵控件。每个按钮都可以独立触发事件或响应。预定义的键映射&#xff1a;lv_keyboard 自带了一套预设的按键布局和对应的字符映射表&#xff0c;开发者可以根据需要选择…

Vue 性能不给力?这些优化技巧帮你轻松搞定!

结合lighthouse查看各项数据&#xff0c;不断进行性能优化&#xff0c;可以从代码、项目打包、项目部署这三个层面来优化 代码层面 1、v-if和v-show区分使用 v-if&#xff08;惰性的&#xff09;用的条件判断&#xff0c;是惰性的&#xff0c;false的话初始不会渲染&#xf…

oracle迁移至gbase,sql问题总结(完善中)

最近再做国产化适配&#xff0c;需要把oracle里面的数据迁移至gbase 8a库中&#xff0c;这边把迁移过程中遇到的sql问题&#xff0c;记录下&#xff0c;现在仅迁移了一部分&#xff0c;后续会继续完善 1.ORACLE里面的NVL2函数在8a中不支持&#xff0c;可换成DECODE函数 2.表别…

二鼠打洞问题

文章目录 二鼠打洞问题测试说明Python求解 二鼠打洞问题 《九章算术》的“盈不足篇”里有一个很有意思的老鼠打洞问题。原文是这么说的&#xff1a;今有垣厚十尺&#xff0c;两鼠对穿。大鼠日一尺&#xff0c;小鼠亦一尺。大鼠日自倍&#xff0c;小鼠日自半。问&#xff1a;何…

此站点正在尝试打开 ,chrome/edge 允许http网站打开url schema

正常https链接会有首次允许选项 但http没有&#xff0c;每次都会弹出&#xff0c;非常烦人。 Chrome / Edge 配置 地址栏输入 chrome://flags/搜索Insecure origins treated as secure, 配置允许网站&#xff0c;需要协议和端口再次跳转会显示始终允许选项