初始JavaEE篇——多线程(7):定时器、CAS

找往期文章包括但不限于本期文章中不懂的知识点:

个人主页:我要学编程程(ಥ_ಥ)-CSDN博客

所属专栏:JavaEE

目录

定时器的使用

定时器的原理 

模拟实现定时器 

CAS

介绍

CAS的应用场景 

解析 AtomicInteger 类

实现自旋锁

CAS的缺陷:ABA问题 


现在我们来学习最后一个多线程的经典案例:定时器。这个与我们日常生活中的闹钟一样,到了一定的时间就开始响个不停,只不过,定时器这里不是响,而是去执行某个任务。

定时器的使用

我们可以来使用一下Java标准库中对应的定时器,对应的类是 Timer。

上面的创建定时器的四个构造方法。

定时器中执行任务的方法是:schedule(这个是把任务添加到队列中,最终的执行还是 run来) 。

TimerTask 是指我们要处理的任务,Date 是指从什么时候开始执行,当前系统的时间+我们设置的时间就是最终的要开始执行任务的时间。 

现在我们就可以来演示:

public class Test {
    public static void main(String[] args) {
        Timer timer = new Timer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("timer执行的第一个任务");
            }
        }, 1000);

        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("timer执行的第二个任务");
            }
        }, 2000);

        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                System.out.println("timer执行的第二个任务");
            }
        }, 3000);

        System.out.println("Hello main");
    }
}

运行结果:

定时器的原理 

定时器就是底层有一个线程,用来接收任务,然后在指定的时间来执行这些任务,如果一个定时器有多个任务,这些任务会根据执行时间的先后关系来存放到一个优先级队列中,时间一到就会执行优先级最高的任务。

模拟实现定时器 

要求:实现和Java标准库中一样的效果。

思路:我们已经知道了定时器是通过 线程+优先级队列 来完成计时完成任务的。线程是用来不断的执行任务的,而优先级队列是用来拿到最先要执行的任务的。那么优先级队列中存储的就是我们要执行的任务以及对应的时间,那么我们可以创建一个任务类,既包含要执行的任务,也包含任务什么时候可以执行,这两个参数。当然,我们也要去实现比较的策略(自定义的类就得去实现),schedule 方法是将任务添加到队列中,让线程去队列中拿任务并执行。

代码实现:

任务类:任务+时间 组成:

class MyTimerTask implements Comparable<MyTimerTask> {
    private Runnable task = null;
    private long time = 0;

    // 要执行的任务和多久执行
    public MyTimerTask(Runnable task, long time) {
        this.task = task;
        this.time = time;
    }

    @Override
    public int compareTo(MyTimerTask o) {
        return (int) (this.time - o.time);
    }

    public long getTime() {
        return time;
    }

    public void run() {
        task.run();
    }
}

定时器类:构造方法+schedule方法:

public class MyTimer {
    private final PriorityQueue<MyTimerTask> queue = new PriorityQueue<>();

    public MyTimer() {
        Thread t = new Thread(()->{
           while (true) { // 确保线程不会被销毁
               synchronized (this) {
                   // 判断队列是否为空
                   while (queue.isEmpty()) {
                       try {
                           this.wait();
                       } catch (InterruptedException e) {
                           throw new RuntimeException(e);
                       }
                   }
                   // 拿到任务
                   MyTimerTask task = queue.peek();
                   // 看看是否到了执行的时机了
                   if (System.currentTimeMillis() < task.getTime()) {
                       try {
                           this.wait(task.getTime() - System.currentTimeMillis());
                       } catch (InterruptedException e) {
                           throw new RuntimeException(e);
                       }
                   } else {
                       // 执行任务并将堆首元素给踢出去
                       task.run();
                       queue.poll();
                   }
               }
           }
        });
        t.start();
    }

    public void schedule(Runnable task, long time) {
        // 把任务添加到队列中
        synchronized (this) {
            // 1、创建任务(任务是什么+任务的执行时刻)
            MyTimerTask myTimerTask = new MyTimerTask(task, time+System.currentTimeMillis());
            // 2、把任务添加到队列中
            queue.offer(myTimerTask);
            // 3、唤醒空队列的阻塞
            this.notify();
        }
    }
}

测试代码:

public class Test {
    public static void main(String[] args) {
        MyTimer myTimer = new MyTimer();
        myTimer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("Hello 3000");
            }
        }, 3000);

        myTimer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("Hello 2000");
            }
        }, 2000);

        myTimer.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("Hello 1000");
            }
        }, 1000);

        System.out.println("main线程结束");
    }
}

运行结果:

CAS

介绍

CAS是一个CPU的指令,全称是 Compare And Swap,比较和交换。这个CAS是一条指令,也就是 比较和交换 的操作是原子的。

下面是CAS的伪代码:

// 假设我们有一个共享变量 value,和一个用于操作的函数 CAS
// CAS函数接受三个参数:内存地址(实际上是指向共享变量的指针)、预期值、要交换的值

boolean CAS(address, expectedValue, swapValue) {
    // 获取内存地址中的当前值
    currentValue = *address
    // 检查当前值是否与预期值相等
    if (currentValue == expectedValue) {
        // 如果相等,将内存地址中的值更新为要交换的值
        *address = swapValue
        return true
    } else {
        // 如果不相等,返回 false,表示交换操作失败
        return false
    }        
}

CAS的应用场景 

既然CAS本身是原子的,那么我们就可以利用这种性质来实现原子类,从而让线程不安全的代码变为线程安全。

Java标准库中提供了 java.util.concurrent.atomic 包,这个包中全部是利用CAS来实现的原子类。

代码演示:

public class Test {
    private static int count1 = 0;
    // 原子类是一个类,注意创建语法
    private static AtomicInteger count2 = new AtomicInteger();
    public static void main(String[] args) {
        // 1、使用普通类、普通的线程的去计算
        countAdd1();
        System.out.println("count1:"+count1);

        // 2、使用原子类、普通的线程去计算
        countAdd2();
        System.out.println("count2:"+count2);
    }

    private static void countAdd2() {
        Thread t1 = new Thread(()->{
            for (int i = 0; i < 100000; i++) {
                count2.getAndAdd(1); // 类似于后置++
            }
        });

        Thread t2 = new Thread(()->{
            for (int i = 0; i < 100000; i++) {
                count2.getAndAdd(1); // 类似于后置++
            }
        });

        t1.start();
        t2.start();

        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }

    private static void countAdd1() {
        Thread t1 = new Thread(()->{
            for (int i = 0; i < 100000; i++) {
                count1++;
            }
        });

        Thread t2 = new Thread(()->{
            for (int i = 0; i < 100000; i++) {
                count1++;
            }
        });

        t1.start();
        t2.start();

        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

运行结果:

从结果我们也可以看出,原子类是本身就是线程安全的,因此就不需要进行加锁操作。 

解析 AtomicInteger 类

当然,上面的方法是先得到旧值,再去进行add操作,即最终得到的是add操作之前的旧值;而 addAndGet 方法是先进行add操作,再返回add操作之后的值,即最终得到的是add操作之后的新值。

原子类之所以会可以保障线程安全,是因为原子类会在进行"写"操作之前,再检查一下寄存器中的值是否与内存中的值是否一致,如果不一致的话,就会去修改寄存器中的值。这样就保障了寄存器中的值与内存中的值在"写"操作之前,一定是一致的,而这个确保机制就是CAS来实现的。

实现自旋锁

CAS也是可以实现自旋锁的。自旋锁是一种乐观锁的策略。与悲观锁相比,其会一直去等待别的线程释放这个锁,并且第一时间拿到这个锁。

private Object locker = null; // 锁


while (!CAS(locker,null,Thread.currentThread())) {

}

public class SpinLock {
    private Object locker = null; // 自旋锁

    // 加锁
    public void lock() {
        // 判断当前锁是否被其他线程持有。
        // 如果被其他线程持有,就会返回false,从而一直循环判断
        // 如果没有被其他线程持有,就会将锁改为当前线程持有,并返回true,退出循环
        while (!CAS(locker,null,Thread.currentThread())) {

        }
    }

    // 解锁    
    private void unlock() {
        locker = null;
    }
}

CAS的缺陷:ABA问题 

任何东西都不可能是完美的,CAS也是一样。CAS虽然会在每次进行"写"操作之前,进行判断内存中的值和寄存器中的值是否一致,但是当中间有个线程突然插一脚将内存的值改为了其他的值,后面又给改回来了呢?这就会导致这次在"写"操作时,可能会带来不可忽略的严重错误。

举个例子(经典案例):

假设小琳银行卡有 100 块钱余额,且假定银行转账操作就是一个单纯的 CAS 命令,对比余额旧值是否与当前值相同,如果相同则发生扣减/增加,我们将这个指令用 CAS(origin,expect) 表示。于是,我们看看接下来发生了什么: 小琳在 ATM 1 转账 100 块钱给小李; 由于ATM 1 出现了网络拥塞的原因卡住了,这时候小琳跑到旁边的 ATM 2 再次操作转账; ATM 2 没让小琳失望,执行了 CAS(100,0),很痛快地完成了转账,此时小琳的账户余额为 0; 小王这时候又给小琳账上转了 100,此时小琳账上余额为 100; 这时候 ATM 1 网络恢复,继续执行 CAS(100,0),居然执行成功了,小琳账户上余额又变为了 0; 这时候小王微信跟小琳说转了 100 过去,是否收到呢?小琳去查了下账,摇了摇头,并未收到账。

分析:

1、最初小琳银行卡余额为 100,我们将这个状态记为 A(余额 100)。

2、当 ATM 2 成功转账后,余额变为 0,这是状态 B(余额 0)。

3、然后小王转账 100,余额又变回 100,这就回到了状态 A(余额 100)。

4、最后 ATM 1 恢复之后,重新检查了小琳的余额,发现与之前的余额是一样的,因此成功执行转账,又将余额变为 0。

整个过程中,余额从 100(A)变成 0(B),然后又变回 100(A),而 CAS 操作只检查余额是否为最初的 100,没有察觉到中间的变化,导致了不符合预期的转账操作。

形成ABA问题的关键:

1、某个线程需要重复读取某个内存地址,并以内存地址的值变化作为该值是否变化的唯一判定依据;

2、重复读取的变量会被多线程共享,且存在『值回退』的可能,即值变化后有可能因为某个操作重新变为原值;

3、在多次读取间隔中,没有采取有效的同步手段,比如,加锁。

以上三个关键点构成了 ABA 问题的充分条件,我们只需要打破其中一个条件就可以解决 ABA 问
题。 

解决方法:

1、最暴力的解决方法就是在转账操作的时候,进行加锁,这样就不会出现别的线程横插一脚了。 

2、在每次的CAS操作中,加入一个正向递增的值,这样即使发生上述情况,下一次去判断时,和上一次的结果就会不一样,最终就不会执行成功或者会更新为最新的情况。这个正向递增的值,可以采用:版本号与时间戳。

好啦!本期 初始JavaEE篇——多线程(7):定时器、CAS 的学习之旅就到此结束啦!我们下一期再一起学习吧!

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

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

相关文章

【UGUI】为射击游戏添加动态显示的分数和血量到UI界面

项目背景 在这个项目中&#xff0c;我们希望实现一个简单的游戏系统&#xff0c;其中玩家可以通过击中目标来获得分数&#xff0c;同时通过与怪物碰撞来减少血量。分数和血量需要在游戏界面上实时显示&#xff0c;以便玩家能够随时了解自己的状态。 技术实现 1. 静态变量的使…

stm32引脚PB3、PB4、PA15作为普通IO口用时,需要先解除调试端口复用

当项目调试的时候&#xff0c;发现PA15引脚无论配置输出高还是低或者输入&#xff0c;均只能输出3.3V的高电平。 目前STM的硬件调试有两种方法&#xff0c;JTAG和SW的方式&#xff0c;目前个人认为最好的方式就是SW&#xff0c;因为它只占用PA13和PA14两个IO。而JTAG还要多占用…

MATLAB与STK互联:仿真并获取低轨卫星与指定区域地面站的可见性数据

MATLAB控制STK实现&#xff1a;仿真并获取低轨卫星与指定区域地面站的可见性数据 本次仿真主要参考了多篇文献和网站&#xff0c;包括但不限于&#xff1a;《Using MATLAB for STK Automation》、CSDN博文&#xff1a; 拜火先知的博客_CSDN博客-笔记、AGI官网有关MATLAB的内容…

用Python设置、更新和获取Excel单元格的值

Excel工作簿作为一款广泛使用的数据管理工具&#xff0c;与Python相结合&#xff0c;可以使得自动化处理大量数据成为可能。通过Python来设置、更新以及读取Excel单元格的值&#xff0c;不仅可以极大地提高工作效率&#xff0c;减少重复劳动&#xff0c;还能增强数据处理流程的…

Golang | Leetcode Golang题解之第525题连续数组

题目&#xff1a; 题解&#xff1a; func findMaxLength(nums []int) (maxLength int) {mp : map[int]int{0: -1}counter : 0for i, num : range nums {if num 1 {counter} else {counter--}if prevIndex, has : mp[counter]; has {maxLength max(maxLength, i-prevIndex)} …

提升网站安全性 HTTPS的重要性与应用指南

内容概要 在如今数字化快速发展的时代&#xff0c;网站安全显得尤为重要。许多用户在访问网站时&#xff0c;尤其是涉及个人信息或金融交易时&#xff0c;对数据传输的安全性有着高度的关注。HTTPS&#xff08;超文本传输安全协议&#xff09;正是为了满足这种需求而诞生的。通…

DICOM标准:解析DICOM属性中的病人模块

目录 病人模块概述 1. 病人关系模块&#xff08;Patient Relationship Module&#xff09; 2. 病人识别模块&#xff08;Patient Identification Module&#xff09; 3. 病人统计模块&#xff08;Patient Demographic Module&#xff09; 4. 病人医学模块&#xff08;Pati…

编写高性能爬虫抓取股票行情数据

最近给一个私募大佬帮忙做了一些股票交易有关的系统&#xff0c;其中涉及到行情数据抓取的问题&#xff0c;一番摸索之后&#xff0c;把成果在这里做个分享。 我把行情抓取的部分&#xff0c;和一个写手记的小功能&#xff0c;单独拿了出来放在一个小系统里面&#xff0c;可以…

人像摄影笔记(自用)

相机的原理&#xff1a;镜头--CMOS传感器---通过ISP的计算 然后通过手机的GPU处理后呈现出图片的形式 镜头&#xff1a;定焦和变焦&#xff0c;变焦分为光学变焦和数字变焦 光学变焦&#xff1a;焦距变了 画质不变 数字变焦&#xff1a;焦距不变 裁剪画质 数字变焦一…

前端埋点与监控最佳实践:从基础到全流程实现.

前端埋点与监控最佳实践&#xff1a;从基础到全流程实现 大纲 我们会从以下三个方向来讲解埋点与监控的知识&#xff1a; 什么是埋点&#xff1f;什么是监控&#xff1f; JS 中实现监控的核心方案 写一个“相对”完整的监控实例 一、什么是埋点&#xff1f;什么是监控&am…

电能质量治理产品在分布式光伏电站的应用

1.概述 随着全球对可再生能源需求的不断增长&#xff0c;分布式光伏电站的建设与扩张正迅速发展。然而&#xff0c;在其运行过程中&#xff0c;分布式光伏电站遭遇了一系列挑战&#xff0c;包括企业关口计量点功率因数降低和谐波污染等问题。这些问题不仅影响了光伏电站的运行…

遥感图像Trento原始数据集下载

遥感图像Trento原始数据集下载 偶然间在某个项目里发现了Trento的完整数据集&#xff0c;不过那个数据集有些奇怪的小改动 虽然我已经不做遥感方向了&#xff0c;不过当初我找这个数据集也是花了很长时间 于是重新整理了一下&#xff0c;就当是方便后来的研究者使用吧 githu…

GenAI 生态系统现状:不止大语言模型和向量数据库

自 20 个月前 ChatGPT 革命性的推出以来&#xff0c;生成式人工智能&#xff08;GenAI&#xff09;领域经历了显著的发展和创新。最初&#xff0c;大语言模型&#xff08;LLMs&#xff09;和向量数据库吸引了最多的关注。然而&#xff0c;GenAI 生态系统远不止这两个部分&#…

个人应用接入使用阿里云盘和百度网盘

一、阿里云盘 官方文档接入流程 语雀流程概述服务端 API 调用流程如下图所示1. 创建账...https://www.yuque.com/aliyundrive/zpfszx/btw0tw 1. 接入授权 1.1. App Key、App Secret和用户授权验证 在通过网盘开发者认证之后&#xff0c;创建个人应用会生成APP ID&#xff…

医院信息化与智能化系统(15)

医院信息化与智能化系统(15) 这里只描述对应过程&#xff0c;和可能遇到的问题及解决办法以及对应的参考链接&#xff0c;并不会直接每一步详细配置 如果你想通过文字描述或代码画流程图&#xff0c;可以试试PlantUML&#xff0c;告诉GPT你的文件结构&#xff0c;让他给你对应…

从比亚迪超越特斯拉,看颠覆全球市场的中国力量

这是比亚迪CEO王传福早年在日本调研电池供应链时发出的感慨。 那时的人们谁也没有想到&#xff0c;比亚迪会从深圳的一家普通的电池供应商开始做起&#xff0c;拼出一条属于自己的“血路”&#xff0c;摇身一变成为名副其实的“电车之王”&#xff0c;并让全球车企仰望。 比亚…

3d 添加辅助坐标器和轨道控制器

1.添加辅助坐标器 使用AxesHelper类来添加坐标轴辅助器&#xff0c;辅助器简单模拟3个坐标轴的对象。红色代表X轴&#xff0c;绿色代表Y轴&#xff0c;蓝色代表Z轴。 // 创建坐标轴辅助器&#xff0c;5是坐标轴的长度 const axesHelper new THREE.AxesHelper(5); // 将坐标轴…

「C/C++」C++标准库之#include<fstream>文件流

✨博客主页何曾参静谧的博客&#x1f4cc;文章专栏「C/C」C/C程序设计&#x1f4da;全部专栏「VS」Visual Studio「C/C」C/C程序设计「UG/NX」BlockUI集合「Win」Windows程序设计「DSA」数据结构与算法「UG/NX」NX二次开发「QT」QT5程序设计「File」数据文件格式「PK」Parasoli…

计算机后台服务-更新下载,重启————未来之窗行业应用跨平台架构

一在教育中应用 1. 提高效率&#xff1a;能够快速收集大量学生的卷子&#xff0c;节省了传统人工收集和整理的时间。 2. 准确性&#xff1a;减少了人工收卷过程中可能出现的错漏和混乱&#xff0c;确保每份卷子都能准确无误地被收集和记录。 3. 即时性&#xff1a;可以实时接收…

奥数与C++小学四年级(第十八题 小球重量)

参考程序代码&#xff1a; #include <iostream> #include <vector>int main() {// 小球的重量std::vector<int> weights {1, 2, 3, 4, 5};// 用来存储可能的结果int a, b, c, d, e, x;// 穷举所有可能的 a, b, c, d, e 的组合for (int i 0; i < weight…