Java小白教学—五千字带你了解多线程机制及线程安全问题

基础概念


 📖 问题一 : 什么是线程?线程和程序、进程有什么区别?

程序:为实现某种功能,使用计算机语言编写的一系列指令的集合。

           指的是静态的代码(例如安装在电脑上的那些文件)

进程:是运行中的程序(如运行中的王者荣耀)进程是操作系统进行资源分配的最小单位。

线程:进程可以进一步细化为线程,是进程中一个最小的执行单元,是cpu进行调度的最小单元

           例如:QQ中的一个聊天窗口

进程和线程的关系:

 •  一个进程中可以包含多个线程. (一个QQ程序可以有多个聊天窗口)

 •  一个线程只能隶属于一个进程. (QQ的聊天窗口只能属于QQ进程)

 •  每一个进程至少包含一个线程,也就是我们的主线程(像java中的main方法就是来启动主线程的)在主线程中可以创建并启动其他线程.

 •  一个进程的线程共享该进程的内存资源.


 📖 问题二 : 什么是多线程?多线程有哪些优缺点?

  ✎. 顾名思义多线程指:在一个程序中可以创建多个线程执行.

优点】 提高程序执行效率(多个任务可以在不同的线程中同时执行)

               提高了cpu的利用率

               改善程序结构,将复杂任务拆分成若干个小任务

缺点】 线程也是程序,线程越多占用内存也越多,cpu开销变大(可扩充内存或升级cpu)

             线程之间同时对共享资源的访问会相互影响,若不加以控制会导致数据出错.


 📖 问题三: 如何解决多线程操作共享数据的问题?

✎. 多个线程同时访问操作同一个共享的数据( 例如买票、抢购等 )时,可能会引起冲突,所以引入

线程 “同步” 机制,即各线程间要有先来后到。

即通过 【 排队+锁 】 在关键的步骤处,使多个线程只能一个一个的执行.

那么问题又来了,什么是锁呢?


锁机制(Lock)


📖 问题四: 什么是锁?锁有什么用?锁怎么用?

✎. 关于synchronized ( 同步锁 )   

语法结构:

   synchronized(同步锁对象) {
        同步代码块      
  }  

同步锁对象作用

用来记录有没有线程进入到同步代码块,如果有线程进入同步代码块,那么其他线程就不能进入同步代码块,直到上一个线程执行完同步代码块的内容,释放锁之后,其他线程才能进入。

同步锁对象要求:   同步锁对象必须是唯一 的。

✎. synchronized还可修饰方法.  

     synchronized修饰方法时,同步锁对象不需要我们指定,同步锁对象会默认提供:

  •     非静态方法 ------  默认是this
  •     静态方法   ------  锁对象是当前类的class对象 (一个类的对象只有一个)

✎. ReentrantLock与synchronized区别?

  • synchronized是一个关键字 ,控制依靠底层编译后的指令去实现.
  • synchronized可以修饰一个方法 或一个代码块.
  • synchronized是 隐式 的加锁和释放锁,一旦方法或代码块出现异常,会自动释放锁.

  • ReentrantLock是一个 ,依靠java底层代码去控制 (底层有一个同步队列)
  • ReentrantLock只能修饰 代码块.
  • ReentrantLock需要 手动 的加锁和释放锁, 所以释放锁最好写在finally中 , 一旦出现异常, 保证锁能释放.

误区:不是只要有线程就需要加锁,只有多个线程对同一资源共享时才加锁

创建线程的方式


 📖 问题五: 如何创建线程?有几种方式?

创建线程的方式通常有三种:

        •  通过继承Thread来创建线程

        •  通过实现Runnable接口来创建线程

        •  通过实现Callable接口来创建线程


📌 通过继承Thread来创建线程                                                                                                        

• 写一个类继承 java.lang.Thread

• 重写run( )

• 线程中要执行的任务都要写在run( )中,或在run( )中进行调用.

public class MyThread extends Thread{//继承Thread类
    @Override
    public void run() {//重写run方法
        for (int i = 1; i <= 200; i++) {
            System.out.println("run"+i);
        }
    }
}
 public static void main(String[] args) {
        //创建线程
        MyThread mythread = new MyThread();
        //启动线程
        mythread.start();
        for (int i = 1; i <= 200; i++) {
            System.out.println("main"+i);
        }
    }

 注意:

      启动线程调用的是start() ; 不是run()

      run()这不是启动线程,只是一个方法调用,没有启动线程,还是单线程模式的。

📖 Thread类中的方法:

run()    用来定义线程要执行的任务代码.
start()  启动线程
currentThread() 获取到当前线程(.得到具体信息)
setName()   为线程设置名字
getState()  获取状态
getPriority() setPriority 获取/设置 优先级
sleep() 让当前线程休眠指定时间.
join()  等待当前线程执行完毕,其他线程再执行.
yield() 主动礼让,退出cpu重新回到等待序列.

📖 关于优先级:

【java中默认优先级为5, 设置优先级范围为1~10】 ( 作用:为操作系统调度算法提供的 )


📌 通过实现Runnable接口来创建线程                                                                                             

• 创建一个类,实现Runnable接口(即只先创建线程要执行的任务)

• 重写任务执行的Run()

• 创建线程,并为线程指定执行任务.

public class MyThread implements Runnable {//实现Runnable接口
    @Override
    public void run() {//重写run方法
        for (int i = 0; i < 200; i++) {
            System.out.println("自定义线程");
        }
    }
}
public static void main(String[] args) {
        //创建任务
        MyThread mythread = new MyThread();
        //创建线程,并指定执行任务
        Thread thread = new Thread(mythread);
        thread.start();
    }

📖 实现Runnable接口创建的优点:

  •  因为java是单继承,一旦继承一个类就不能在继承其他类,避免单继承的局限。

  •  适合多线程来处理同一份资源时使用


📌 通过实现Callable接口来创建线程                                                                                               

 • 相比run( )方法,可以有返回值.

 • 方法可以抛出异常.

 • 支持泛型的返回值.

 • 需要借助FutureTask类,获取返回结果 

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class CallableDemo<T> implements Callable<T> {
    @Override
    public T call() throws Exception {//可以有返回值,也可以抛出异常
        Integer n = 0;
        for (int i = 0; i < 10; i++) {
            n += i;
        }
        return (T) n;
    }

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CallableDemo<Integer> callableDemo = new CallableDemo();
        FutureTask<Integer> futureTask = new FutureTask<Integer>(callableDemo);
        Thread thread = new Thread(futureTask);
        thread.start();
        System.out.println(futureTask.get());
    }
}

 这段代码是打印1~10的和,通过这个案例,相信你对实现Callable接口来创建线程已经大致了解

核心代码:

  CallableDemo<Integer> callableDemo = new CallableDemo();
        FutureTask<Integer> futureTask = new FutureTask<Integer>(callableDemo);
        Thread thread = new Thread(futureTask);
        thread.start();
        System.out.println(futureTask.get());

线程生命周期


📖 问题六: 一个线程的生命周期是怎样的?

线程状态:

新建:刚刚创建了一个线程对象,并没有启动.

就绪:调用start() 后线程就进入到了就绪状态(可运行状态),进入到了操作系统的调度队列.

运行状态:获得了cpu执行权,进入到cpu执行.

阻塞状态:例如调用sleep() ,有线程调用了join(),线程中进行Scanner输入...

死亡/销毁:run()方法中的任务执行完毕了.

状态关系图:

模拟卖票案例: 两个窗口分别售票,票数为10张

public class MyThread extends Thread{//我们使用了继承Thread的方法
    static int num =10;   //票总数10,且为共享资源,要用static修饰
    static String obj = new String();//可以是任意类对象,但必须唯一。
/*  synchronized(同步锁对象) {
         同步代码块
    }                         */

    @Override
    public void run() {//线程要执行的代码块要写在run()中
        while (true){
            synchronized (obj){//加锁,一次只能执行一个线程
                if(num>0){
                    try {
                        Thread.sleep(800);//此处加入休眠为了让运行结果更明显,也可不加
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName()+"买到了第"+num+"张票");
                    num--;  //每抢一张票,总数num(10)就减1
                }else{
                    break;
                }
            }
        }
    }
}

在Main方法中创建线程并启动: 

 
public static void main(String[] args) {
        //创建两个线程,分别对应两个窗口
        MyThread myThread1 = new MyThread();
        myThread1.setName("窗口1");//线程1
        myThread1.start();

        MyThread myThread2 = new MyThread();
        myThread2.setName("窗口2");//线程2
        myThread2.start();
    }

运行结果: 

线程通信


📖 问题七: 什么是线程通信?怎么实现线程交替运行?

✎. 线程通信指:多个线程相互调度, 相互牵制,即线程间的相互作用.

wait( )   --- 让线程等待同时释放锁.

notify( ) --- 唤醒等待线程,必须写在同步代码块中进行,必须通过锁对象调用。

notifyAll( )--唤醒所有等待的线程.

这三个方法必须使用在同步代码块或同步方法中


✎. sleep( long time )与wait( )区别:

sleep ( ) :

  • 属于Thread类中的方法
  • sleep休眠指定时间后,会自动唤醒
  • sleep( ) 不会释放锁

wait ( ) :

  • 属于Object类中的方法,必须要有锁对象调用
  • wait后的线程必须要等待其他线程唤醒(notify或notifyAll)
  • wait( ) 自动释放锁

让我们通过一个例题来体会下线程通信吧!

两个线程交替打印1-100之间的数字

public class MyThread extends Thread{
    static int num = 1;
    static String string =new String();
    @Override
    public void run() {
        while (num<=100){
            synchronized (string){
                string.notify();

                System.out.println(currentThread().getName()+":"+num);
                num++;

                try {
                    string.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    public static void main(String[] args) {
        MyThread mythread1 = new MyThread();
        mythread1.start();
        MyThread mythread2 = new MyThread();
        mythread2.start();
    }
}

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

UE5 编辑器启动模式下去掉左上角的Clink for Mouse Control

Edit > Editor Preferences > Game Gets Mouse Control 把这个勾去掉

【C++初阶】C++简单入门(长期维护)

本篇博客是对C的一些简单知识分享&#xff0c;有需要借鉴即可。 C简单入门目录 一、C前言1.C的概念&#xff1a;2.C发展历程3.C如何学&#xff1f; 二、C入门1.C关键字(C98标准)2.命名空间3.C输入&输出①概念说明②使用说明③特征说明④细节拓展⑤cout与cin的意义 4.缺省参…

freertos作业day1

1.总结keil5下载代码和编译代码需要注意的事项 1.&#xff09;仿真器设置&#xff1a; 点击魔术棒&#xff0c;选择debug选项&#xff0c;找到使用的仿真器&#xff0c;选择ST-LINK仿真器&#xff0c;点击setting&#xff0c;选择flash download ,勾选reset and run,选择pack…

竞技游戏新纪元:如何打造满足现代玩家需求的极致体验?

文章目录 一、现代玩家需求分析二、以玩家体验为核心的游戏设计三、个性化与定制化服务四、强化社交互动与社区建设五、持续更新与优化《游戏力&#xff1a;竞技游戏设计实战教程》亮点编辑推荐内容简介目录获取方式 随着科技的飞速发展和游戏产业的不断壮大&#xff0c;现代玩…

负荷预测 | Matlab基于TCN-GRU-Attention单变量时间序列多步预测

目录 效果一览基本介绍程序设计参考资料 效果一览 基本介绍 1.Matlab基于TCN-GRU-Attention单变量时间序列多步预测&#xff1b; 2.单变量时间序列数据集&#xff0c;采用前12个时刻预测未来96个时刻的数据&#xff1b; 3.excel数据方便替换&#xff0c;运行环境matlab2023及以…

DNF手游攻略:萌新入坑大全!

玩DNF手游国服已经正式定档&#xff0c;离上线已经越来越近了&#xff0c;很多小伙伴对于装备打造以及附魔还不是特别了解。如果你还不知道装备要怎么附魔&#xff0c;不要担心&#xff0c;本篇攻略将为你全面解析全职业过渡和毕业附魔推荐。 ​ 一、物理职业附魔推荐 1. 武器…

渗透测试信息收集

一、渗透信息收集流程 渗透测试过程前期&#xff0c;需要大量的完善的网站业务信息收集工作&#xff0c;大致信息收集流程为 1、网站域名信息探测 2、网站子域信息探测 3、网站敏感信息收集 4、网站安全工具核实 5、网站旁站利用情况 6、网站业务资产梳理 二、网站域名信息探…

【行为型模式】策略模式

一、策略模式概述 策略模式(又叫政策Policy模式)&#xff0c;属于对象行为模式下的&#xff1a;Strategy类提供了可插入式(Pluggable)算法的实现方案。 策略模式的定义-意图&#xff1a;定义一系列算法&#xff0c;将每一个算法封装起来&#xff0c;并让它们互相替换。策略模式…

.NET MVC API Swagger 自动生成API文档入坑

开发环境 Win10 VS2022 .NET8.0 1.从NuGet添加Swagger 在解决方案资源管理器中右键单击项目>管理 NuGet 包 将包源设置为“nuget.org” 确保启用“包括预发行”选项 在搜索框中输入“Swashbuckle.AspNetCore” 从“浏览”选项卡中选择最新的“Swashbuckle.AspNetCore”包&a…

OCCT几何内核开发-TopoDS_Shape

如果要基于OCCT几何内核搞建模算法&#xff0c;特别是想开发自己的算法&#xff0c;需要深刻理解拓扑与几何的关系、相关的数据结构&#xff0c;TopoDS_Shape、TopoDS_TShape、BRep_TFace、Tolerances等。 一个简单Box的数据结构 两个面缝合&#xff08;Sewing&#xff09;后的…

优惠券布局的最终方案------css属性mask

先贴图&#xff1a; 以上这些都是通过mask去实现出来&#xff1a; <!DOCTYPE html><html lang"zh-CN"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"&g…

【多模态检索】Coarse-to-Fine Visual Representation

快手文本视频多模态检索论文 论文&#xff1a;Towards Efficient and Effective Text-to-Video Retrieval with Coarse-to-Fine Visual Representation Learning 链接&#xff1a;https://arxiv.org/abs/2401.00701 摘要 近些年&#xff0c;基于CLIP的text-to-video检索方法…

FreeRTOS_day1

1.总结keil5下载代码和编译代码需要注意的事项 下载代码前要对仿真进行设置 勾选后代码会立刻执行 勾选后会导致代码不能执行 写代码的时候要写在对应的begin和end之间&#xff0c;否则会被覆盖 2.总结STM32Cubemx的使用方法和需要注意的事项 ①打开软件&#xff0c;新建工程…

初学python记录:力扣924. 尽量减少恶意软件的传播

题目&#xff1a; 给出了一个由 n 个节点组成的网络&#xff0c;用 n n 个邻接矩阵图 graph 表示。在节点网络中&#xff0c;当 graph[i][j] 1 时&#xff0c;表示节点 i 能够直接连接到另一个节点 j。 一些节点 initial 最初被恶意软件感染。只要两个节点直接连接&#x…

BK9535可替代BK9531 BEKEN博通 无线高品质语音发射传输芯片 提供开发资料

概 述 BK9531已经停产&#xff0c;厂家推出升级替代芯片BK9535 BK9535芯片是用于无线高品质语音发射传输的芯片&#xff0c;芯片覆盖频段范围为&#xff1a;V段&#xff08;160~270MHz&#xff09;、U段&#xff08;450~980MHz&#xff09;、1G频段&#xff08;980~1176MHz&a…

一款可自动跳广告的安卓App开源项目

开放权限有风险&#xff0c;使用App需谨慎&#xff01; gkd 基于 无障碍 高级选择器 订阅规则 的自定义屏幕点击 APP 功能 基于 高级选择器 订阅规则 快照审查, 它可以实现 点击跳过任意开屏广告/点击关闭应用内部任意弹窗广告, 如关闭百度贴吧帖子广告卡片/知乎回答底…

HarmonyOS开发案例:【智能煤气检测】

样例简介 智能煤气检测系统通过实时监测环境中烟雾浓度&#xff0c;当一氧化碳浓度超标时&#xff0c;及时向用户发出警报。在连接网络后&#xff0c;配合数字管家应用&#xff0c;用户可以远程配置智能煤气检测系统的报警阈值&#xff0c;远程接收智能煤气检测系统报警信息。…

华为再次布局新行业:合作伙伴已超前谋划,该领域将大有可为

华为布局新行业 华为向外界公布了一个重要信息&#xff1a;在过去的三年里&#xff0c;尽管受到美国的制裁&#xff0c;华为仍然成功地完成了超过13000个元器件的国产替代研发&#xff0c;以及4000多块电路板的迭代开发。 不仅在硬件领域取得了显著成就&#xff0c;在软件和生…

AutoMQ 登顶 Hacker News: 开源项目流量的第一桶金以及经验分享

01 事件回顾 2024 年 4 月 8 日中午&#xff0c;随着 AutoMQ 的一则简短的标题内容&#xff1a;Show HN: AutoMQ - A Cost-Effective Kafka Distro That Can Autoscale in Seconds[1] 成功登顶 Hacker News &#xff08;HN&#xff09; &#xff0c;我们迎来了大量优质、精准的…

为什么一开始不被看好的单片机,现在概括了所有数据产品行业?

这主要归因于技术和认知的局限。 在其发展初期&#xff0c;单片机的性能、存储容量以及开发工具都颇为有限&#xff0c;难以契合复杂应用的种种需求。彼时&#xff0c;许多人确实难以洞察到它的未来走向。 然而&#xff0c;时过境迁&#xff0c;人们逐步领悟到了单片机在各个…