一文打通java线程

news2024/11/27 4:14:57

基本概念:程序、进程、线程

程序(program)

是为完成特定任务、用某种语言编写的一组指令的集合。即指一 段静态的代码,静态对象。

进程(process)

是程序的一次执行过程,或是正在运行的一个程序。是一个动态的过程:有它自身的产生、存在和消亡的过程。——生命周期

如:运行中的QQ,运行中的MP3播放器

程序是静态的,进程是动态的

进程作为资源分配的单位,系统在运行时会为每个进程分配不同的内存区域

线程(thread)

进程可进一步细化为线程,是一个程序内部的一条执行路径。

若一个进程同一时间并行执行多个线程,就是支持多线程的

线程作为调度和执行的单位,每个线程拥有独立的运行栈和程序计数器(pc),线程切换的开销小

一个进程中的多个线程共享相同的内存单元/内存地址空间它们从同一堆中分配对象,可以 访问相同的变量和对象。这就使得线程间通信更简便、高效。但多个线程操作共享的系统资 源可能就会带来安全的隐患。

 单核CPU和多核CPU的理解

 单核CPU,其实是一种假的多线程,因为在一个时间单元内,也只能执行一个线程 的任务。例如:虽然有多车道,但是收费站只有一个工作人员在收费,只有收了费 才能通过,那么CPU就好比收费人员。如果有某个人不想交钱,那么收费人员可以 把他“挂起”(晾着他,等他想通了,准备好了钱,再去收费)。但是因为CPU时间单元特别短,因此感觉不出来。

 如果是多核的话,才能更好的发挥多线程的效率。(现在的服务器都是多核的)

 一个Java应用程序java.exe,其实至少有三个线程:main()主线程,gc()垃圾回收线程,异常处理线程。当然如果发生异常,会影响主线程。

并行与并发

 并行:多个CPU同时执行多个任务。比如:多个人同时做不同的事。

 并发:一个CPU(采用时间片)同时执行多个任务。比如:秒杀、多个人做同一件事

背景:以单核CPU为例,只使用单个线程先后完成多个任务(调用多个方法),肯定比用多个线程来完成用的时间更短,为何仍需多线程呢?

多线程程序的优点:

1. 提高应用程序的响应。对图形化界面更有意义,可增强用户体验。

2. 提高计算机系统CPU的利用率

3. 改善程序结构。将既长又复杂的进程分为多个线程,独立运行,利于理解和修改

何时需要多线程

 程序需要同时执行两个或多个任务。

 程序需要实现一些需要等待的任务时,如用户输入、文件读写操作、网络操作、搜索等。

 需要一些后台运行的程序时

线程的创建和使用 

注意:

下面的程序不是多线程!

public class Sample {

    public void method1(String str) {

        System.out.println(str);
    }

    public void method2(String str) {

        method1(str);

    }

    public static void main(String[] args) {
        Sample s = new Sample();

        s.method2("hello!");

    }
}

线程的创建和启动  

Java语言的JVM允许程序运行多个线程,它通过java.lang.Thread类来体现。

Thread类的特性

        每个线程都是通过某个特定Thread对象的run()方法来完成操作的,经常 把run()方法的主体称为线程体

        通过该Thread对象的start()方法来启动这个线程,而非直接调用run()

 Thread类

 构造器

Thread():创建新的Thread对象

Thread(String threadname):创建线程并指定线程实例名

Thread(Runnable target):指定创建线程的目标对象,它实现了Runnable接口中的run方法

Thread(Runnable target, String name):创建新的Thread对象

API中创建线程的两种方式

 JDK1.5之前创建新执行线程有两种方法:

 继承Thread类的方式

 实现Runnable接口的方式

方式一:继承Thread类

1) 定义子类继承Thread类。

2) 子类中重写Thread类中的run方法。

3) 创建Thread子类对象,即创建了线程对象。

4) 调用线程对象start方法:启动线程,调用run方法。

  注意点:

1. 如果自己手动调用run()方法,那么就只是普通方法,没有启动多线程模式。

2. run()方法由JVM调用,什么时候调用,执行的过程控制都有操作系统的CPU

调度决定。

3. 想要启动多线程,必须调用start方法。

4. 一个线程对象只能调用一次start()方法启动,如果重复调用了,则将抛出以上 的异常“IllegalThreadStateException”。

方式二:实现Runnable接口

1) 定义子类,实现Runnable接口。

2) 子类中重写Runnable接口中的run方法。

3) 通过Thread类含参构造器创建线程对象。

4) 将Runnable接口的子类对象作为实际参数传递给Thread类的构造器中。

5) 调用Thread类的start方法:开启线程,调用Runnable子类接口的run方法。

 继承方式和实现方式的联系与区别

public class Thread extends Object implements Runnable

 区别

 继承Thread:线程代码存放Thread子类run方法中。

 实现Runnable:线程代码存在接口的子类的run方法。

 实现方式的好处

 避免了单继承的局限性

 多个线程可以共享同一个接口实现类的对象,非常适合多个相同线 程来处理同一份资源。

 Thread类的有关方法

void start(): 启动线程,并执行对象的run()方法

run(): 线程在被调度时执行的操作

String getName(): 返回线程的名称

void setName(String name):设置该线程名称

static Thread currentThread(): 返回当前线程。在Thread子类中就是this,通常用于主线程和Runnable实现类

static void yield():线程让步

        暂停当前正在执行的线程,把执行机会让给优先级相同或更高的线程

        若队列中没有同优先级的线程,忽略此方法

join() :当某个程序执行流中调用其他线程的 join() 方法时,调用线程将 被阻塞,直到join() 方法加入的 join 线程执行完为止

        低优先级的线程也可以获得执行

static void sleep(long millis):(指定时间:毫秒)

        令当前活动线程在指定时间段内放弃对CPU控制,使其他线程有机会被执行,时间到后 重排队。

        抛出InterruptedException异常

stop(): 强制线程生命期结束,不推荐使用

boolean isAlive():返回boolean,判断线程是否还活着

线程的调度  

调度策略

时间片

抢占式:高优先级的线程抢占CPU

Java的调度方法

同优先级线程组成先进先出队列(先到先服务),使用时间片策略

对高优先级,使用优先调度的抢占式策略

 线程的优先级

 线程的优先级等级

        MAX_PRIORITY:10

        MIN _PRIORITY:1

        NORM_PRIORITY:5

 涉及的方法

        getPriority() :返回线程优先值

        setPriority(int newPriority) :改变线程的优先级

说明

        线程创建时继承父线程的优先级

        低优先级只是获得调度的概率低,并非一定是在高优先级线程之后才被调用

补充:线程的分类

Java中的线程分为两类:一种是守护线程,一种是用户线程。

 它们在几乎每个方面都是相同的,唯一的区别是判断JVM何时离开。

 守护线程是用来服务用户线程的,通过在start()方法前调用thread.setDaemon(true)可以把一个用户线程变成一个守护线程。

 Java垃圾回收就是一个典型的守护线程。

 若JVM中都是守护线程,当前JVM将退出。

 形象理解:兔死狗烹,鸟尽弓藏

线程的生命周期 

 JDK中用Thread.State类定义了线程的几种状态

要想实现多线程,必须在主线程中创建新的线程对象。Java语言使用Thread类 及其子类的对象来表示线程,在它的一个完整的生命周期中通常要经历如下的五 种状态:

新建: 当一个Thread类或其子类的对象被声明并创建时,新生的线程对象处于新建 状态

就绪:处于新建状态的线程被start()后,将进入线程队列等待CPU时间片,此时它已具备了运行的条件,只是没分配到CPU资源

运行:当就绪的线程被调度并获得CPU资源时,便进入运行状态, run()方法定义了线 程的操作和功能

阻塞:在某种特殊情况下,被人为挂起或执行输入输出操作时,让出 CPU 并临时中止自己的执行,进入阻塞状态

死亡:线程完成了它的全部工作或线程被提前强制性地中止或出现异常导致结束

 

 

线程的同步 

问题的提出

多个线程执行的不确定性引起执行结果的不稳定

多个线程对账本的共享,会造成操作的不完整性,会破坏数据。

 

 

class Ticket implements Runnable {

    private int tick = 100;

    public void run() {

        while (true) {

            if (tick > 0) {

                System.out.println(Thread.currentThread().getName() + "售出车票,tick号为:" + tick--);
            } else
                break;

        }

    }
}
class TicketDemo {

    public static void main(String[] args) {

        Ticket t = new Ticket();

        Thread t1 = new Thread(t);

        Thread t2 = new Thread(t);
        Thread t3 = new Thread(t);

        t1.setName("t1窗口");

        t2.setName("t2窗口");

        t3.setName("t3窗口");

        t1.start();

        t2.start();

        t3.start();
    }

}

 

 

 

1. 多线程出现了安全问题

2. 问题的原因:

当多条语句在操作同一个线程共享数据时,一个线程对多条语句只执行了一部分,还没有 执行完,另一个线程参与进来执行。导致共享数据的错误。

3. 解决办法:

对多条操作共享数据的语句,只能让一个线程都执行完,在执行过程中,其他线程不可以 参与执行。

 Synchronized的使用方法

java对于多线程的安全问题提供了专业的解决方式:同步机制

1. 同步代码块:

synchronized (对象){

// 需要被同步的代码;

}

2. synchronized还可以放在方法声明中,表示整个方法为同步方法。

例如:

public synchronized void show (String name){ …. }

同步机制中的锁 

在《Thinking in Java》中,是这么说的:对于并发工作,你需要某种方式来防 止两个任务访问相同的资源(其实就是共享资源竞争)。 防止这种冲突的方法 就是当资源被一个任务使用时,在其上加锁。第一个访问某项资源的任务必须 锁定这项资源,使其他任务在其被解锁之前,就无法访问它了,而在其被解锁 之时,另一个任务就可以锁定并使用它了。

 synchronized的锁是什么?

 任意对象都可以作为同步锁。所有对象都自动含有单一的锁(监视器)。

 同步方法的锁:静态方法(类名.class)、非静态方法(this)

 同步代码块:自己指定,很多时候也是指定为this或类名.class

 注意:

 必须确保使用同一个资源的多个线程共用一把锁,这个非常重要,否则就无法保证共享资源的安全

 一个线程类中的所有静态方法共用同一把锁(类名.class),所有非静态方 法共用同一把锁(this),同步代码块(指定需谨慎)

 同步的范围

1、如何找问题,即代码是否存在线程安全?(非常重要)

(1)明确哪些代码是多线程运行的代码

(2)明确多个线程是否有共享数据

(3)明确多线程运行代码中是否有多条语句操作共享数据

2、如何解决呢?(非常重要)

对多条操作共享数据的语句,只能让一个线程都执行完,在执行过程中,其 他线程不可以参与执行。

即所有操作共享数据的这些语句都要放在同步范围中

3、切记:

 范围太小:没锁住所有有安全问题的代码

 范围太大:没发挥多线程的功能。

释放锁的操作

 当前线程的同步方法、同步代码块执行结束。

 当前线程在同步代码块、同步方法中遇到break、return终止了该代码块、 该方法的继续执行。

 当前线程在同步代码块、同步方法中出现了未处理的Error或Exception,导致异常结束。

 当前线程在同步代码块、同步方法中执行了线程对象的wait()方法,当前线 程暂停,并释放锁。

 

不会释放锁的操作 

 线程执行同步代码块或同步方法时,程序调用Thread.sleep()、Thread.yield()方法暂停当前线程的执行

线程执行同步代码块时,其他线程调用了该线程的suspend()方法将该线程

挂起,该线程不会释放锁(同步监视器)。

应尽量避免使用suspend()和resume()来控制线程

 单例设计模式之懒汉式(线程安全)

 

class Singleton {
    private static Singleton instance = null;

    private Singleton(){}

    public static Singleton getInstance(){

        if(instance==null){
            synchronized(Singleton.class){
                if(instance == null){

                    instance=new Singleton();

                }
            } 
        }
        return instance;
    } }
public class SingletonTest{

    public static void main(String[] args){

        Singleton s1=Singleton.getInstance();
        Singleton s2=Singleton.getInstance();
        System.out.println(s1==s2);
    } 
}

线程的死锁问题 

 死锁

不同的线程分别占用对方需要的同步资源不放弃,都在等待对方放弃自己需要的同步资源,就形成了线程的死锁

出现死锁后,不会出现异常,不会出现提示,只是所有的线程都处于 阻塞状态,无法继续

解决方法

专门的算法、原则

尽量减少同步资源的定义

尽量避免嵌套同步

 

 

3. Lock(锁)

 从JDK 5.0开始,Java提供了更强大的线程同步机制——通过显式定义同步锁对象来实现同步。同步锁使用Lock对象充当。

 java.util.concurrent.locks.Lock接口是控制多个线程对共享资源进行访问的 工具。锁提供了对共享资源的独占访问,每次只能有一个线程对Lock对象加锁,线程开始访问共享资源之前应先获得Lock对象。

 ReentrantLock 类实现了 Lock ,它拥有与 synchronized 相同的并发性和 内存语义,在实现线程安全的控制中,比较常用的是ReentrantLock,可以显式加锁、释放锁。

class A{
    private final ReentrantLock lock = new ReenTrantLock();
    public void m(){

        lock.lock();

        try{
//保证线程安全的代码;
        }

        finally{

            lock.unlock();

        }
    }
}

注意:如果同步代码有异常,要将unlock()写入finally语句块  

synchronized 与 Lock 的对比  

1. Lock是显式锁(手动开启和关闭锁,别忘记关闭锁),synchronized是 隐式锁,出了作用域自动释放

2. Lock只有代码块锁,synchronized有代码块锁和方法锁

3. 使用Lock锁,JVM将花费较少的时间来调度线程,性能更好。并且具有更好的扩展性(提供更多的子类)

优先使用顺序:

Lock --->同步代码块(已经进入了方法体,分配了相应资源) --->同步方法(在方法体之外)

线程的通信 

wait() 与 notify() 和 notifyAll()

 wait():令当前线程挂起并放弃CPU、同步资源并等待,使别的线程可访问并修改共享资源,而当 前线程排队等候其他线程调用notify()或notifyAll()方法唤醒,唤醒后等待重新获得对监视器的所有 权后才能继续执行。

 notify():唤醒正在排队等待同步资源的线程中优先级最高者结束等待

 notifyAll ():唤醒正在排队等待资源的所有线程结束等待.

 这三个方法只有在synchronized方法或synchronized代码块中才能使用,否则会报java.lang.IllegalMonitorStateException异常。

 因为这三个方法必须有锁对象调用,而任意对象都可以作为synchronized的同步锁, 因此这三个方法只能在Object类中声明。

 wait() 方法

在当前线程中调用方法: 对象名.wait()

使当前线程进入等待(某对象)状态 ,直到另一线程对该对象发出 notify(或notifyAll) 为止。

调用方法的必要条件:当前线程必须具有对该对象的监控权(加锁)

调用此方法后,当前线程将释放对象监控权 ,然后进入等待

在当前线程被notify后,要重新获得监控权,然后从断点处继续代码的执行。

notify()/notifyAll()  

在当前线程中调用方法: 对象名.notify()

功能:唤醒等待该对象监控权的一个/所有线程。

调用方法的必要条件:当前线程必须具有对该对象的监控权(加锁)

 

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

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

相关文章

Linux常用命令——sort命令

在线Linux命令查询工具(http://www.lzltool.com/LinuxCommand) sort 将文件进行排序并输出 补充说明 sort命令是在Linux里非常有用,它将文件进行排序,并将排序结果标准输出。sort命令既可以从特定的文件,也可以从stdin中获取输入。 语法…

文本情感分类TextCNN原理+IMDB数据集实战

1.任务背景 情感分类: 发展历程: 2.数据集 本次使用IMDB数据集进行训练。 3.模型结构 3.1 CNN基础 卷积: 单通道卷积:每组卷积核只包含一个。 单通道输入 单输出:设置一组卷积核。 单通道输入 多输出:…

国企避坑:to B服务性质的业务线不要来!又卷又累,互联网和它比简直是小巫见大巫!...

国企好归好,但不是所有的国企都能闭眼入,一位网友友情提示大家:不管是国企还是央企,to b服务性质的业务线不要来,不要来,不要来!又卷又累,苦哈哈,互联网和这个比&#xf…

在CSS世界的权力——权重

在CSS的世界中也存在着权力即CSS权重 1. 概念 CSS权重指的是样式的优先级,有两条或多条样式作用于一个元素,权重高的那条样式对元素起作用,权重相同的,后写的样式会覆盖前面写的样式 2. 以前的BUG 在实际开发中,我…

代码随想录--双指针章节总结

代码随想录–双指针章节总结 1.LeetCode27 移除元素 给你一个数组 nums 和一个值 val,你需要 原地 移除所有数值等于 val 的元素,并返回移除后数组的新长度。 不要使用额外的数组空间,你必须仅使用 O(1) 额外空间并 原地 修改输入数组。 …

C++程序设计——动态内存管理

一、C/C内存分布 1.栈(堆栈) 存储非静态局部变量、函数参数、返回值等等,栈是向下增长。 2.内存映射段 是高效的I/O映射方式,用于转载一个共享的动态内存库。用户可使用系统接口创建共享内存,做进程间通信。 3.堆 用…

WPS的简单JS宏应用

有一阵子没写博客了,各种琐事忙碌;前段时间接触了下WPS的宏功能,抽点时间写个学习笔记吧。 案例背景简单说一下,主任让我统计OA后台在建工程项目的概况,后台数据导出一张表,再问隔壁经营部的同事要了一张中…

java类的初始化2023018

类的初始化: 第一次使用某个类,例如Person类,系统通常会在第一次使用Person类时加载这个类并初始化这个类。在类的准备阶段,系统将会为该类的类变量分配内存空间,并指定默认初始值。当Person类初始化完成后&#xff0c…

机器学习笔记之深度玻尔兹曼机(二)深度玻尔兹曼机的预训练过程

机器学习笔记之深度玻尔兹曼机——深度玻尔兹曼机的预训练过程引言深度信念网络预训练过程的问题深度玻尔兹曼机的预训练过程(2023/1/24)引言 上一节介绍了玻尔兹曼机系列的相关模型,本节将介绍深度玻尔兹曼机的预训练过程。 深度信念网络预训练过程的问题 在玻尔…

Escher 愛雪磁磚設計法則 - 高雄燕巢深水國小科展指導

“Talk is cheap. Show me the code.” ― Linus Torvalds 老子第41章 上德若谷 大白若辱 大方無隅 大器晚成 大音希聲 大象無形 道隱無名 拳打千遍, 身法自然 “There’s no shortage of remarkable ideas, what’s missing is the will to execute them.” – Seth Godin …

GreenPlum AOCO列存如何将数据刷写磁盘

GreenPlum AOCO列存如何将数据刷写磁盘AOCO列存表每个字段一个文件,前面我们介绍了列存表如何加载数据页,本文我们重点介绍AOCO表如何进行刷写。AOCO表进行insert、update、delete会产生脏数据,和heap表的异步脏页刷写不同,AOCO表…

写一个锅炉温控系统用python编写

简单来说就是锅炉水热了之后循环泵自动开启,然后将热水输送走,送到暖气,热水抽走,凉水进入锅炉,温度降低,循环泵关闭,等待下一次水烧热。因为需要取暖的房子距离烧锅炉的地方比较远,所以需要循环泵,如果距离近的话水烧热后利用热水上流冷水回流的原理会自动完成循环。…

前言技术之mybatis-plus

目录 1.什么是mybatis-plus 2.初体验 3.日志 4.主键生成策略 5.更新 6.自动填充 1.什么是mybatis-plus 升级版的mybatis,目的是让mybatis更易于使用, 用官方的话说“为简化而生” 官网: MyBatis-Plus 2.初体验 1.准备数据库脚本 数据…

BI 解决方案:BimlStudio 22.3.0 Crack

全功能开发环境:::: 导入现有解决方案 通过添加 BimlScript 自动化进行更改并重新生成包;使您的解决方案更好、更快。 可视化整个 BI 解决方案 通过我们的可视化设计器在一个位置进行更改,观察您的整个解决方案自行更新…

【ArcGIS微课1000例】0061:ArcGIS打开xyz格式点云数据的方法

本文讲述ArcMap和ArcScene中如何打开xyz格式的点云数据并做可视化的方法。 文章目录 一、xyz格式点云简介二、ArcMap打开xyz点云三、ArcScene打开xyz点云四、注意事项一、xyz格式点云简介 本实验使用的数据是配套数据包中的0061.rar,斯坦福大学的点云数据,格式为X,Y,Z,如下…

【My Electronic Notes系列——晶闸管】

目录 序言: 🏮🏮新年的钟声响,新年的脚步迈,祝新年的钟声,敲响你心中快乐的音符,幸运与平安,如春天的脚步紧紧相随,春节快乐!春华秋实,我永远与你…

Linux下动静态库的打包与使用C C++

目录前言为什么用动静态库动态链接与静态链接底层优缺点Linux下的动静态库动静态库的对比打包静态库使用静态库打包动态库使用动态库小结win下打包动静态库前言 为什么用动静态库 我们在实际开发中,经常要使用别人已经实现好的功能,这是为了开发效率和…

移动窗口下的LiDAR点云区域生长滤波算法教程

一、前言LiDAR 滤波的现有方法包括:数学形态学滤波法、基于地形坡度滤波、最小二乘内插法滤波等滤波方法。最小二乘内插法能够较好的获取地形趋势面,但是算法中无法根据地形自适应设置参数;在地形起伏较大的地区提取结果精度低;无…

Linux进程的后台运行

文章目录一. 什么是进程?二. 进程后台运行在了解三种进程后台运行的方式前,小编觉得有必要先简单讲解一下什么是进程。 PS: 本篇博客技术参考价值不大,只是类似随笔比较水,详细的知识点可以关注一下nohup命令的使用。 一. 什么是进程? 什…

00开篇词:带你玩转gRPC框架

前言 大家好,先做一下自我介绍 我叫Barry Yan,目前是一名互联网公司的研发工程师,同时也是后端技术领域的狂热爱好者和技术博主,在GitHub、CSDN社区、51CTO博客社区、阿里云技术社区、掘金技术社区和InfoQ写作社区等都有自己的博…