JavaEE初阶Day 3:多线程(1)

目录

  • Day 3:多线程(1)
    • 1. 线程
      • 1.1 引入线程的原因
      • 1.2 线程的定义
      • 1.3 为何线程更轻量
      • 1.4 问题
    • 2. 多线程代码
      • 2.1 继承Thread重写run
      • 2.2 通过实现Runnable接口创建线程
      • 2.3 针对2.1的变形使用匿名内部类
      • 2.4 针对Runnable创建匿名内部类
      • 2.5 使用lambda表达式

Day 3:多线程(1)

C++会对进程有更进一步介绍,例如:如何通过编写代码,来进行进程的控制(多进程编程),但是Java并不太关注这些

  • JVM没有提供上述多进程编程的api
  • Java生态中也不太鼓励使用多进程编程

JVM也不是完全没有,也提供了非常粗糙的多进程操作的api,但是控制过程不如C++通过系统原生api更精细

1. 线程

1.1 引入线程的原因

当前的CPU都是多核心CPU,需要通过一些特定的编程技巧,把要完成的任务,拆解成多个部分,并且分别让他们在不同的CPU核心上运行,也就是**“并发编程”**

  • 通过多进程编程的模式,其实就可以起到“并发编程”的效果,因为进程可以被调度到不同的CPU上运行,此时就可以把多个CPU核心都给很好的利用起来,虽然,多进程编程可以解决上述问题,也带来了新的麻烦
  • 在服务器开发中,并发编程的需求场景非常常见,所以一个服务器要能够同时给多个客户端提供服务,如果同一时间,来了很多客户端,服务器如果只能利用一个CPU核心工作,速度就会比较慢
  • 一种典型的做法:每个客户端连上服务器了,服务器都创建一个进程,给客户端提供服务,这个客户端断开了,服务器再把进程给释放掉,如果这个服务器,频繁的有客户端来来去去,服务器就需要频繁创建/销毁进程

所以引入线程,来解决上述进程“太重量”的问题

1.2 线程的定义

线程(thread),也称为“轻量级进程”,创建和销毁的开销更小,线程可以理解成“进程的一部分”,一个进程中可以包含一个线程或者多个线程,描述进程,使用PCB这样的结构体,事实上,更严格地说,一个PCB其实是描述一个线程的,若干个PCB联合在一起,是描述一个进程的

PCB:pid(每个线程都不一样)、内存指针、文件描述符表、状态、上下文、优先级、记账信息、tgid(同一个进程的tgid是同一个)

同一个进程的若干个线程,是共用相同的内存资源和文件资源的,这里的内存指针和文件描述符表其实是同一个,但是每个线程都是独立在CPU上调度执行

  • 进程是系统分配资源的基本单位
  • 线程是系统调度执行的基本单位

引入线程后,就可以每个客户端分配一个线程来处理,起到优化效果

1.3 为何线程更轻量

为什么线程比进程更轻量/为什么说线程创建和销毁的开销比进程更小

核心在于,创建进程,可能要包含多个线程,这个过程中,涉及到资源分配/资源释放,创建线程,相当于资源已经有了,省去了资源分配/资源释放步骤了,同一个进程包含N个线程,这些线程之间是共用资源的,只有创建第一个线程(也是创建进程的时候),去进行资源申请操作,后续再创建线程,都没有申请资源的过程了

1.4 问题

  • 线程不能无限引入:总的线程越多,单位时间内要进行调度的次数也越多,调度消耗的系统资源自然就更多了,这个时候,线程调度开销就会非常明显,程序的性能可能不升反降
  • 线程安全问题:多个线程之间可能产生冲突
  • 如果一个线程抛出异常,并且没有很好的捕获处理好,就会使得整个进程退出,多线程编程值得关注的难点:一个线程出现问题,会影响到别的线程

2. 多线程代码

线程本身是操作系统提供的,操作系统提供了api让我们操作线程,JVM就对操作系统api进行了封装,Java中提供了Thread类,表示线程

2.1 继承Thread重写run

  • public void run():run只是描述了线程要干啥任务,run不是start调用的,是start创建出来的线程,线程里被调用的

  • t.start();Thread类中自带的方法,调用操作系统提供的“创建线程”api,在内核中创建对应的PCB,并且把PCB加入到链表中,进一步的系统调度到这个线程之后,就会执行上述run方法中的逻辑

像run这种方法,只是定义好,而不用去手动调用,把这个方法的调用,交给系统/其他的库/其他的框架(别人)调用这样的方法(函数)称为**“回调函数”**(callback function)

package thread;class MyThread extends Thread {@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}public class Demo1 {public static void main(String[] args) {Thread t = new MyThread();t.start();for (int i = 0; i < 5; i++) {System.out.println("hello main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

上述代码中有两个线程

  • t 线程
  • main方法所在的线程(主线程):JVM进程启动的时候,自己创建的线程

JDK中包含了jconsole工具,通过这个工具可以更直观地看到内部进程的情况,里面除了main与t线程,剩下的线程,都是JVM帮我们做的一些其他工作,有的是负责垃圾回收的,有的是负责记录调试信息的

Thread.sleep(1000);:让线程主动进入“阻塞状态”,主动放弃去CPU上执行,时间到了之后,线程才会接触阻塞状态,重新被调度到CPU上执行,加上sleep就让CPU消耗的资源大幅度降低了,不加入sleep,消耗CPU资源将会特别大,while循环太快了

未来实际开发中,如果服务器程序消耗CPU的资源超出预期,如何排查

  • 先确认是哪个线程消耗的CPU比较高,未来会涉及到到第三方工具,可以看到每个线程的CPU的消耗情况,确定了之后,进一步排查,线程中是否有类似的“非常快速”的循环
  • 确认清楚,这里的循环是否应该这么快,如果应该,说明需要升级更好的CPU,如果不应该,说明需要在循环中引入一些"等待操作"(不一定是sleep)

上述代码补充说明

  • 每秒钟打印一次,每一秒打印的时候,可能是main在前面,也可能是thread在前面
  • 多个线程的调度顺序,是无序的,在操作系统内部称为**“抢占式执行”**,任何一个线程,在执行到任何一个代码的过程中,都可能被其他线程抢占掉它的CPU资源,于是CPU就给别的线程执行了
  • 这样的抢占式执行,充满了随机性,正是这样的随机性,使多线程程序的执行效果也会难以预测,甚至可能会引入bug
  • 主流的系统(Linux、Windows)都是属于这种实现方式,也有一些小众的系统(实时操作系统),通过“协商式”进行调度,虽然牺牲了很多功能,换来了调度的实时性

2.2 通过实现Runnable接口创建线程

  • Runnable的作用,是描述了一个“任务”,这个任务和具体的执行机制无关(通过线程的方式执行,还是通过其他的方式执行),run就是要执行的任务内容本身了

  • 引入Runnable就是为了解耦合,未来如果要更换其他的方式来执行这些任务,改动成本比较低,把任务内容和线程这个概念给拆分开了,这样的任务,就可以给其他的地方来执行

package thread;
class MyRunnable implements Runnable {@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}public class Demo2 {public static void main(String[] args) {Thread t = new Thread(new MyRunnable());t.start();for (int i = 0; i < 5; i++) {System.out.println("hello main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}}

2.3 针对2.1的变形使用匿名内部类

package thread;public class Demo3 {public static void main(String[] args) {Thread t = new Thread() {@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}};t.start();for (int i = 0; i < 5; i++) {System.out.println("hello main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

此处的new Thread()

  • 创建了一个Thread的子类(不知道啥名字,匿名)
  • 同时创建了一个该子类的实例:对于匿名内部类来说,只能创建这一个实例,之后再也拿不到这个匿名内部类了
  • 此处的子类内部重写了父类的run方法

2.4 针对Runnable创建匿名内部类

package thread;public class Demo4 {public static void main(String[] args) {Thread t = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}});t.start();for (int i = 0; i < 5; i++) {System.out.println("hello main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

此处匿名内部类,只是针对Runnable,和Thread没有关系,只是把Runnable的实例,作为参数传入到了Thread的构造方法中

  • 创建新的类,实现Runnable,但是类的名字是匿名的
  • 创建了这个新类的实例(一次性)
  • 重写run方法

2.5 使用lambda表达式

lambda本质上就是针对匿名内部类的平替

package thread;public class Demo5 {public static void main(String[] args) {Thread t = new Thread(() ->{for (int i = 0; i < 5; i++) {System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}});t.start();for (int i = 0; i < 5; i++) {System.out.println("hello main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

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

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

相关文章

Lora人机界面开发 3

1 显示原理 液晶的形成&#xff1a;像水一样液晶介于固态和液态之间 偏光原理&#xff1a;两块偏光的栅栏角度相互垂直时光线就完全无法通过 内部结构&#xff1a;利用电场控制液晶分支的旋转 颜色深度 TFT开关的工作原理&#xff1a; 扫描线连接同一列所有TFT栅极电极&…

通过mapreduce程序统计旅游订单(wordcount升级版)

通过mapreduce程序统计旅游订单&#xff08;wordcount升级版&#xff09; 本文将结合一个实际的MapReduce程序案例&#xff0c;探讨如何通过分析旅游产品的预订数据来揭示消费者的偏好。 程序概览 首先&#xff0c;让我们来看一下这个MapReduce程序的核心代码。这个程序的目…

创新视角:探索系统产品可用性测试的前沿分类方法与实践应用

一、可用性测试概念 1、什么是可用性&#xff1f; 任何与人可以发生交互的产品都应该是可用的&#xff0c;就一般产品而言&#xff0c;可用性被定义为目标用户可以轻松使用产品来实现特定目标。 ISO9241/11中的定义是&#xff1a; 一个产品可以被特定的用户在特定的场景中&a…

数据结构之二叉树和平衡二叉树

1、二叉树&#xff1a; package com.datastructure.tree; //一个常用的第三方库是Apache Commons Collections&#xff0c;它提供了一个名为BinaryTree的类&#xff0c;用于表示二叉树。 //可以使用org.apache.commons.collections4.BinaryTree类创建二叉树和进行操作。 //可以…

跨越时空,启迪智慧:奇趣相机重塑儿童摄影与教育体验

【科技观察】近期&#xff0c;奇趣未来公司以其创新之作——“奇趣相机”微信小程序&#xff0c;强势进军儿童AI摄影市场。这款专为亚洲儿童量身定制的应用&#xff0c;凭借精准贴合亚洲儿童面部特征的AIGC大模型&#xff0c;以及丰富的摄影模板与场景设定&#xff0c;正在重新…

Ps:匹配颜色

匹配颜色 Match Color命令可以将一个图像的颜色与另一个图像的颜色相匹配。 Ps菜单&#xff1a;图像/调整/匹配颜色 Adjustments/Match Color 匹配颜色命令可匹配多个图像之间、多个图层之间或者多个选区之间的颜色&#xff0c;还可以通过更改亮度和色彩范围以及中和色痕来调整…

Day17-【Java SE进阶】特殊文本文件、日志技术

一、特殊文本文件 为什么要用这些特殊文件&#xff1f; 存储多个用户的&#xff1a;用户名、密码 存储有关系的数据&#xff0c;做为系统的配置文件做为信息进行传输 日志技术 把程序运行的信息&#xff0c;记录到文件中&#xff0c;方便程序员定位bug、并了解程序的执行情…

Java并发编程基础面试题详细总结

1. 什么是线程和进程? 1.1 何为进程? 进程是程序的一次执行过程&#xff0c;是系统运行程序的基本单位&#xff0c;因此进程是动态的。系统运行一个程序即是一个进程从创建&#xff0c;运行到消亡的过程。 在 Java 中&#xff0c;当我们启动 main 函数时其实就是启动了一个…

课时84:流程控制_select条件控制_案例实践

1.5.2 案例实践 学习目标 这一节&#xff0c;我们从 case实践、软件部署、小结 三个方面来学习。 case实践 实践3-整合case实践 查看脚本内容 [rootlocalhost ~]# cat simple_select_case.sh #!/bin/bash # select语句的使用# 定制普通环境变量 PS3请选择菜单序号: # 定制…

Solidity全局变量完全测试

Solidity全局变量完全测试 我们知道,在Solidity中有很多全局变量,例如我们最常用的msg.sender, block.timestamp 等。但是有一些我们平常基本接触不到,例如:type(C).name等。本着凡事最怕认真两字的原则,虽然繁琐,但我们将所有的全局变量全部测试一遍,学习怎么调用和应用…

Windows进程监视器Process Monitor

文章目录 Process Monitor操作逻辑 Process Monitor Process Monitor是 Windows 的高级监视工具&#xff0c;是Filemon Regmon的整合增强版本&#xff0c;实时显示文件系统&#xff0c;注册表&#xff0c;网络活动&#xff0c;进程或线程活动&#xff0c;资料收集事件&#x…

阿里云弹性计算通用算力型u1实例性能评测,性价比高

阿里云服务器u1是通用算力型云服务器&#xff0c;CPU采用2.5 GHz主频的Intel(R) Xeon(R) Platinum处理器&#xff0c;ECS通用算力型u1云服务器不适用于游戏和高频交易等需要极致性能的应用场景及对业务性能一致性有强诉求的应用场景(比如业务HA场景主备机需要性能一致)&#xf…

记录一次threejs内存泄露问题排查过程

问题描述&#xff1a; 一个有关地图编辑的使用threejs的这样的组件&#xff0c;在多次挂载销毁后&#xff0c;页面开始卡顿。 问题排查&#xff1a; 1. 首先在chrome dev tool中打开performance monitor面板&#xff0c;观察 JS head size、DOME Nodes、Js event listeners数…

函数式编程Haskell基础介绍之基础类型、Glasgow的使用

纯函数式编程是一种编程范式&#xff0c;它的核心思想是通过纯函数的方式来进行编程。纯函数指的是函数的输出仅依赖于输入&#xff0c;并且没有副作用&#xff08;side effects&#xff09;。换句话说&#xff0c;相同的输入始终产生相同的输出&#xff0c;而且函数不会改变任…

5.108 BCC工具之virtiostat.py解读

一,工具简介 virtiostat程序用于跟踪virtio设备以分析IO操作和吞吐量。 例如,客户端挂载了一个9pfs,而我们再也无法通过iostat命令获取IO统计信息。 在这种情况下,我们只能从VIRTIO层而不是块层获取统计信息。 示例 二,代码示例 #!/usr/bin/env pythonfrom __future__…

【C++】C++11类的新功能

&#x1f440;樊梓慕&#xff1a;个人主页 &#x1f3a5;个人专栏&#xff1a;《C语言》《数据结构》《蓝桥杯试题》《LeetCode刷题笔记》《实训项目》《C》《Linux》《算法》 &#x1f31d;每一个不曾起舞的日子&#xff0c;都是对生命的辜负 目录 前言 默认成员函数 类成…

Java基于微信小程序高校体育场管理小程序

博主介绍&#xff1a;✌IT徐师兄、7年大厂程序员经历。全网粉丝15W、csdn博客专家、掘金/华为云//InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专栏推荐订阅&#x1f447;&#x1f3…

跨域问题解决方案之CORS

跨域问题解决方案之CORS 文章目录 跨域问题解决方案之CORS概述浏览器的同源策略同源的判定规则目的同源策略的限制范围 浏览器的同源策略为什么会引发跨域问题&#xff1f;CORS规则CORS解决方案CORS方案将请求分为两类举例简单请求预检请求总结学以致用 概述 浏览器安全的基石…

esp32控制舵机---待完善

舵机有三个引脚&#xff0c;分别是电源、电源GND和信号线。如下图所示&#xff1a; ESP32-WROOM-32E的引脚的定义如下&#xff1a; 图来自乐鑫官网:ESP32-DevKitC V4 入门指南 - ESP32 - — ESP-IDF 编程指南 v5.2.1 文档 硬件连接图&#xff1a; 待补充

Failed to resolve import “Home/components/HomeNew.vue“. Does the file exist?

错误信息 [plugin:vite:import-analysis] Failed to resolve import "/apis/home.js" from "src/views/Home/components/HomeNew.vue". Does the file exist? 错误原因 路径错误 解决方法