Java线程池和原子性

文章目录

  • 前言
  • 1 线程池
    • 1.1 线程池概述
      • 1.1.1 线程池存在的意义
      • 1.1.2 Executors默认线程池
    • 1.2 线程状态介绍
      • 1.2.1 线程状态源码
      • 1.2.2 线程状态含义
      • 1.2.3 线程状态转换图
  • 2 原子性
    • 2.1 volatile关键字
    • 2.2 synchronized解决
    • 2.3 原子性
    • 2.4 AtomicInteger类
    • 2.5 悲观锁和乐观锁

前言

“清琴浊酒莺花日，雨笠烟蓑蟹稻乡。棠荫渐高身渐隐，已将心事托渔郎”   —张英 《赠何匡山次梅村先生韵》
在这里插入图片描述

1 线程池

1.1 线程池概述

       线程池也是可以看做成一个容器，在该容器中存储很多个线程。

1.1.1 线程池存在的意义

       系统创建一个线程的成本是比较高的，频繁的创建和销毁线程对系统的资源消耗非常大，所为了提高性能，我们就可以采用线程池。线程池在启动的时，会创建大量空闲线程，当我们向线程池提交任务的时，线程池就会启动一个线程来执行该任务。等待任务执行完毕以后，线程并不会死亡，而是再次返回到线程池中称为空闲状态。等待下一次任务的执行。

1.1.2 Executors默认线程池

       1.常见方法

// 1.创建一个默认的线程池
static ExecutorService newCachedThreadPool()
// 2.创建一个指定最多线程数量的线程池
static newFixedThreadPool(int nThreads)

       2.代码实现 :

package com.syh;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


public class MyThread {
    public static void main(String[] args) throws InterruptedException {

        // 1,创建一个默认的线程池对象
        ExecutorService executorService = Executors.newCachedThreadPool();
        executorService.submit(()->{
            System.out.println(Thread.currentThread().getName() + "在执行了");
        });
        // 2,等待2秒
        Thread.sleep(2000);
        executorService.submit(()->{
            System.out.println(Thread.currentThread().getName() + "在执行了");
        });
        executorService.shutdown();
    }
}

1.2 线程状态介绍

       线程对象在不同的时期有不同的状态，一共有6种状态

1.2.1 线程状态源码

public class Thread {
    
    public enum State {
    
        /* 新建 */
        NEW , 

        /* 可运行状态 */
        RUNNABLE , 

        /* 阻塞状态 */
        BLOCKED , 

        /* 无限等待状态 */
        WAITING , 

        /* 计时等待 */
        TIMED_WAITING , 

        /* 终止 */
        TERMINATED;
    
	}
    
    // 获取当前线程的状态
    public State getState() {
        return jdk.internal.misc.VM.toThreadState(threadStatus);
    }
    
}

1.2.2 线程状态含义

线程状态具体含义
NEW一个尚未启动的线程的状态。也称之为初始状态、开始状态。线程刚被创建，但是并未启动。还没调用start方法。MyThread t = new MyThread()只有线程象，没有线程特征。
RUNNABLE当我们调用线程对象的start方法，那么此时线程对象进入了RUNNABLE状态。那么此时才是真正的在JVM进程中创建了一个线程，线程一经启动并不是立即得到执行，线程的运行与否要听令与CPU的调度，那么我们把这个中间状态称之为可执行状态(RUNNABLE)也就是说它具备执行的资格，但是并没有真正的执行起来而是在等待CPU的度。
BLOCKED当一个线程试图获取一个对象锁，而该对象锁被其他的线程持有，则该线程进入Blocked状态；当该线程持有锁时，该线程将变成Runnable状态。
WAITING一个正在等待的线程的状态。也称之为等待状态。造成线程等待的原因有两种，分别是调用Object.wait()、join()方法。处于等待状态的线程，正在等待其他线程去执行一个特定的操作。例如：因为wait()而等待的线程正在等待另一个线程去调用notify()或notifyAll()；一个因为join()而等待的线程正在等待另一个线程结束。
TIMED_WAITING一个在限定时间内等待的线程的状态。也称之为限时等待状态。造成线程限时等待状态的原因有三种，分别是：Thread.sleep(long)，Object.wait(long)、join(long)。
TERMINATED一个完全运行完成的线程的状态。也称之为终止状态、结束状态

1.2.3 线程状态转换图

在这里插入图片描述

2 原子性

2.1 volatile关键字

1. 问题 :

当A线程修改了共享数据时，B线程没有及时获取到最新的值，如果还在使用原先的值，就会出现问题

  • 堆内存是唯一的，每一个线程都有自己的线程栈。

  • 每一个线程在使用堆里面变量的时候，都会先拷贝一份到变量的副本中。

  • 在线程中，每一次使用是从变量的副本中获取的。

2. Volatile解决 : 强制线程每次在使用的时候，都会看一下共享区域最新的值,代码示例如下：

package com.syh;

public class Money{
    public static volatile int money = 1000;
}

package com.syh;

public class MyThread1 extends Thread{
    @Override
    public void run() {
        Money.money -= 100;
        System.out.println("李默然：" + Money.money);
    }
}

package com.syh;

public class MyThread2 extends Thread{
    @Override
    public void run() {
        System.out.println("林北辰：" + Money.money);
    }
}

package com.syh;

public class Test {
    public static void main(String[] args) {
        MyThread1 t1 = new MyThread1();
        t1.start();

        MyThread2 t2 = new MyThread2();
        t2.start();
    }
}

2.2 synchronized解决

1. synchronized解决步骤 :

  • 线程获得锁

  • 清空变量副本

  • 拷贝共享变量最新的值到变量副本中

  • 执行代码

  • 将修改后变量副本中的值赋值给共享数据

  • 释放锁

2. 代码实现 :

package com.syh;

public class Money{
    public static Object lock = new Object();
    public static int money = 1000;
}

package com.syh;

public class MyThread1 extends Thread{
    @Override
    public void run() {
        synchronized (Money.lock){
            Money.money -= 100;
            System.out.println("李默然: " + Money.money);
        }
    }
}

package com.syh;

public class MyThread2 extends Thread{
    @Override
    public void run() {
        synchronized (Money.lock){
            System.out.println("林北辰：" + Money.money);
        }
    }
}

package com.syh;

public class Test {
    public static void main(String[] args) {
            MyThread1 t1 = new MyThread1();
            t1.start();

            MyThread2 t2 = new MyThread2();
            t2.start();
        }
}

2.3 原子性

       原子性就是要么所有的操作都执行，要么所有的操作都不执行，多个操作是一个不可以分割的整体。

2.4 AtomicInteger类

java从JDK1.5开始提供了AtomicInteger类，这个包中的原子操作类提供了一种用法简单，性能高效，线程安全地更新一个变量的方式，常用方法如下:

public AtomicInteger()：	   			    // 1.初始化一个默认值为0的原子型Integer
public AtomicInteger(int initialValue)： // 2.初始化一个指定值的原子型Integer

int get():   			 				 // 3.获取值
int getAndIncrement():      			 // 4.以原子方式将当前值加1，注意，这里返回的是自增前的值。
int incrementAndGet():     				 // 5.以原子方式将当前值加1，注意，这里返回的是自增后的值。
int addAndGet(int data): // 6.以原子方式将输入的数值与实例中的值（AtomicInteger里的value）相加，并返回结果。
int getAndSet(int value):   			 // 7.以原子方式设置为newValue的值，并返回旧值。

代码实现 :

package com.syh;

import java.util.concurrent.atomic.AtomicInteger;

public class MyAtom {
    public static void main(String[] args) {
        AtomicInteger ac = new AtomicInteger();
        System.out.println(ac);

        AtomicInteger ac2 = new AtomicInteger(10);
        System.out.println(ac2);
    }
}

2.5 悲观锁和乐观锁

synchronized和CAS的区别是什么?

1. 相同点
       在多线程情况下，都可以保证共享数据的安全性。

2.不同点

  • 悲观锁：synchronized总是从最坏的角度出发，认为每次获取数据的时候，别人都有可能修改。所以在每次操作共享数据之前，都会上锁。

  • 乐观锁：cas是从乐观的角度出发，假设每次获取数据别人都不会修改，所以不会上锁。只不过在修改共享数据的时候，会检查一下，别人有没有修改过这个数据。

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

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

相关文章

代码随想录算法训练营第56天 | 1、冗余连接，2、冗余连接II

代码随想录算法训练营第56天 | 1、冗余连接，2、冗余连接II

目录 1、冗余连接 2、冗余连接II 1、冗余连接 题目描述 有一个图，它是一棵树，他是拥有 n 个节点（节点编号1到n）和 n - 1 条边的连通无环无向图（其实就是一个线形图），如图： 现在在…
阅读更多...
JavaScript 学习

JavaScript 学习

一、输出 为方便调试可以输出内容&#xff0c;但是用户是看不到的。要在开发者模式中看。 console . log ( "Hello" )&#xff1b; 二、外部文件引用 可以直接在html中写JS <head> <meta charset"utf-8"> <script> console.log("he…
阅读更多...
RFID手持机——物联网时代的核心工具

RFID手持机——物联网时代的核心工具

一、行业背景 在当今物联网技术高速发展的时代&#xff0c;RFID技术作为核心的数据采集与识别手段&#xff0c;在物流、仓储、资产管理等众多领域发挥着至关重要的作用。以物流行业为例&#xff0c;利用RFID技术能够对货物进行全程精准跟踪&#xff0c;从入库、存储、搬运到出…
阅读更多...
每日OJ题_牛客_NC40链表相加（二）_链表+高精度加法_C++_Java

每日OJ题_牛客_NC40链表相加（二）_链表+高精度加法_C++_Java

目录 牛客_NC40链表相加&#xff08;二&#xff09;_链表高精度加法 题目解析 C代码 Java代码 牛客_NC40链表相加&#xff08;二&#xff09;_链表高精度加法 链表相加(二)_牛客题霸_牛客网 题目解析 模拟⾼精度加法的过程&#xff0c;只不过是在链表中模拟。 C代码 /*…
阅读更多...
buuctf [ACTF2020 新生赛]Include

buuctf [ACTF2020 新生赛]Include

学习笔记。 开启靶机。 进入靶场&#xff1a; 我们跟进 tips瞅瞅&#xff1a; 额&#xff0c;纯小白&#xff0c;能想到的就是先F12看看&#xff0c;在CTRLu、以及抓包。 得&#xff0c;不会了&#xff0c;看wp呗&#xff0c;不会死磕没脑子0,0&#xff1f; 参考&#xff1a;…
阅读更多...
JPA + Thymeleaf 增删改查

JPA + Thymeleaf 增删改查

一、 什么是 Thymeleaf JPA&#xff08;Java Persistence API&#xff09;&#xff1a;是一种用于对象关系映射&#xff08;ORM&#xff09;的 Java 规范&#xff0c;它简化了数据库操作&#xff0c;使开发者可以以面向对象的方式处理数据存储。通过定义实体类和数据访问接口&a…
阅读更多...
探索5 大 Node.js 功能

探索5 大 Node.js 功能

目录 单线程 Node.js 工作线程【Worker Threads】 Node.js 进程 进程缺点 工作线程 注意 集群进程模块【Cluster Process Module】 内部发生了什么&#xff1f; 为什么要使用集群 注意&#xff1a; 应用场景&#xff1a; 内置 HTTP/2 支持 这个 HTTP/2 是什么&…
阅读更多...
vscode使用yarn 启动vue项目记录

vscode使用yarn 启动vue项目记录

第一次启动yarn项目&#xff0c;这个是公司的老项目&#xff0c;遇到了点问题&#xff0c;记录下首先是我一般使用的是npm命令&#xff0c;所以没有安装yarn vscode安装yarn vscode进入到该项目文件夹下&#xff0c;输入命令&#xff1a;npm install -g yarn 安装成功后&…
阅读更多...
实时数字人DH_live使用案例

实时数字人DH_live使用案例

参看： https://github.com/kleinlee/DH_live ubuntu 测试 apt install ffmpeg 下载安装： git clone https://github.com/kleinlee/DH_live.git cd DH_liveconda create -n dh_live python=3.12 conda activate dh_live pip install -r requirements.txt pip install torch -…
阅读更多...
小程序开发设计-小程序的宿主环境：组件⑦

小程序开发设计-小程序的宿主环境：组件⑦

上一篇文章导航&#xff1a; 小程序开发设计-小程序的宿主环境&#xff1a;宿主环境简介⑥-CSDN博客https://blog.csdn.net/qq_60872637/article/details/142425131?spm1001.2014.3001.5501 注&#xff1a;不同版本选项有所不同&#xff0c;并无大碍。 目录 上一篇文章导航…
阅读更多...
助力降本增效，ByteHouse打造新一代云原生数据仓库

助力降本增效，ByteHouse打造新一代云原生数据仓库

随着数据量的爆炸式增长、企业上云速度加快以及数据实时性需求加强&#xff0c;云原生数仓市场迎来了快速发展机遇。 据 IDC、Gartner 研究机构数据显示&#xff0c;到 2025 年&#xff0c;企业 50% 数据预计为云存储&#xff0c;75% 数据库都将运行在云上&#xff0c;全球数据…
阅读更多...
责任链模式实战

责任链模式实战

责任链模式实战
阅读更多...
在conda环境中使用pip管理Python项目依赖

在conda环境中使用pip管理Python项目依赖

在前面的内容中&#xff0c;我们学习了如何使用conda来创建和管理Python虚拟环境。虽然conda本身是一个强大的包管理工具&#xff0c;但在某些情况下&#xff0c;你可能仍然需要使用pip来安装某些库或依赖项。这是因为并非所有的Python库都支持conda安装&#xff0c;有时最新的…
阅读更多...
iOS OC 底层原理之 category、load、initialize

iOS OC 底层原理之 category、load、initialize

文章目录 category底层结构runtime 执行 category 底层原理添加成员变量 load调用形式系统调用形式的内部原理源码实现逻辑 initialize调用形式源码核心函数&#xff08;由上到下依次调用&#xff09;如果分类实现了 initialize category 底层结构 本质是结构体。struct _cat…
阅读更多...
SentencePiece进行文本分类

SentencePiece进行文本分类

SentencePieces 前言 Step1:故事 SentencePiece 是一个无监督的文本分词器和 detokenizer(还原回去的&#xff1f;)主要用于词汇表大小是预定的文本生成系统中它拓展了原始句子的训练&#xff0c;实现子词单元如 BPE 和 unigram language model技术亮点 纯数据驱动&#xff…
阅读更多...
那年我双手插兜，使用IPv6+DDNS动态域名解析访问NAS

那年我双手插兜，使用IPv6+DDNS动态域名解析访问NAS

估计有很多科技宅和我一样&#xff0c;会买一个NAS存储或者自己折腾刷一下黑群晖玩玩&#xff0c;由于运营商不给分配固定的公网IP&#xff0c;就导致我在外出的时候无法访问家里的NAS&#xff0c;于是远程访问常常受到IP地址频繁变动的困扰。为了解决这一问题&#xff0c;结合…
阅读更多...
【HTTP】请求“报头”，Referer 和 Cookie

【HTTP】请求“报头”，Referer 和 Cookie

Referer 描述了当前这个页面是从哪里来的&#xff08;从哪个页面跳转过来的&#xff09; 浏览器中&#xff0c;直接输入 URL/点击收藏夹打开的网页&#xff0c;此时是没有 referer。当你在 sogou 页面进行搜索时&#xff0c;新进入的网页就会有 referer 有一个非常典型的用…
阅读更多...
gitlab默认克隆地址的修改

gitlab默认克隆地址的修改

目录 1.找到opt/gitlab/embedded/service/gitlab-rails/config目录&#xff0c;打开gitlab.yml 2.修改地址和端口 3.重启gitlab 1.找到opt/gitlab/embedded/service/gitlab-rails/config目录&#xff0c;打开gitlab.yml cd /opt/gitlab/embedded/service/gitlab-rails/confi…
阅读更多...
jmeter断言---响应断言

jmeter断言---响应断言

请求http://www.baidu.com 检查&#xff1a;让程序检查响应数据中是否包含“百度一下&#xff0c;你就知道” 操作步骤&#xff1a; 1.添加线程组 2.添加http请求 3.添加断言&#xff08;需要在http请求下添加断言&#xff0c;而且可以根据断言测试字段等信息新建不同的断…
阅读更多...
docker-图形化工具-portainer的使用

docker-图形化工具-portainer的使用

文章目录 1、安装和启动2、设置登陆密码3、dashboard 上述对容器和镜像的管理都是基于docker客户端的命令来完成&#xff0c;不太方便。为了方便的对docker中的一些对象(镜像、容器、数据卷…)来进行管理&#xff0c;可以使用Portainer来完成。Portainer是一个可视化的容器镜像…
阅读更多...
最新文章

Copyright @ 2022~2023