当前位置: 首页 > news >正文

深入理解Java单例模式和优化多线程任务处理

目录

  • 饿汉模式
  • 懒汉模式
    • 单线程版
    • 多线程版
    • 双重检查锁定
  • 阻塞队列

单例模式能保证某个类在程序中只存在唯一一份实例, 而不会创建出多个实例,并提供一个全局访问点。

饿汉模式

类加载的同时,创建实例。
在这里插入图片描述

class  Singleton {private static final Singleton instance = new Singleton();//将构造方法设为私有,以防止外部通过new关键字创建新的实例。private Singleton() {}public static Singleton getInstance() {return instance;}
}
  • 上述代码定义了一个名为Singleton的类。
  • 在类中定义了一个私有的静态常量instance,它是Singleton类的一个唯一实例。
  • 提供了一个公共的静态方法getInstance(),用于获取Singleton类的唯一实例。

懒汉模式

类加载的时候不创建实例,第一次使用的时候才进行创建。
在这里插入图片描述

单线程版

class Singleton {private static Singleton instance = null;private Singleton() {}public static Singleton getInstance() {if (instance == null) {instance = new Singleton();}return instance;}
}

多线程版

上述单线程代码在多线程中就会出现错误,多个线程同时调用getInstance()方法时,就可能导致创建出多个实例是不安全的。这里我们只需要在getInstance()方法中添加synchronized关键字就可解决。

class Singleton {private static Singleton instance = null;private Singleton() {}public synchronized static Singleton getInstance() {if (instance == null) {instance = new Singleton();}return instance;}
}

双重检查锁定

class Singleton {//volatile关键字保证了instance变量在多线程环境下的可见性。private static volatile Singleton instance = null;private Singleton() {}public synchronized static Singleton getInstance() {if (instance == null) {synchronized (Singleton.class){if (instance == null ){instance = new Singleton();}}}return instance;}
}

双重检查可以这样进行理解:
第一次if先判断实例有没有被创建,如果没被创建就进入第一个if内,使一个线程成功获取锁(其余线程进行阻塞等待),线程获取锁后再次进行判断,判断实例是否创建,没有创建就进行创建。当这个实例创建完了之后,其他竞争到锁的线程就被里层 if 挡住了,也就不会继续创建其他实例。

阻塞队列

阻塞队列能是一种线程安全的数据结构, 并且具有以下特性:

  • 当队列满的时候, 继续入队列就会阻塞, 直到有其他线程从队列中取走元素.
  • 当队列空的时候, 继续出队列也会阻塞, 直到有其他线程往队列中插入元素.

阻塞队列的一种典型应用场景就是生产者消费者模型。

在 Java 标准库中内置了阻塞队列。 如果我们需要在一些程序中使用阻塞队列,直接使用标准库中的即可。

  • BlockingQueue 是一个接口,真正实现的类是 LinkedBlockingQueue
  • put 方法用于阻塞式的入队列,take 用于阻塞式的出队列
  • BlockingQueue 也有 offer, poll, peek 等方法, 但这些方法不带有阻塞特性

下面我们来实现一个阻塞队列:

  • 通过循环队列的方式
  • 使用 synchronized 进行加锁控制
public class BlockingQueue {private int[] arr = new int[1000];private volatile int size = 0;private int tail = 0;private int head = 0;public void put(int value) throws InterruptedException {synchronized (this) {while (size == arr.length) {wait();}arr[tail] = value;tail = (tail + 1) % arr.length;size++;notifyAll();}}public int take() throws InterruptedException {int ret = 0;synchronized (this) {while (size == 0) {wait();}ret = arr[head];head = (head + 1) % arr.length;size--;notifyAll();}return ret;}public static void main(String[] args) throws InterruptedException {BlockingQueue bq = new BlockingQueue();Thread t1 = new Thread(() -> {try {for (int i = 0; i < 10; i++) {bq.put(i);System.out.println("生产者放入:" + i);Thread.sleep(1000);}} catch (InterruptedException e) {e.printStackTrace();}});t1.start();Thread t2 = new Thread(() -> {try {for (int i = 0; i < 10; i++) {int num = bq.take();System.out.println("消费者取出:" + num);Thread.sleep(1000);}} catch (InterruptedException e) {e.printStackTrace();}});t2.start();t1.join();t2.join();}
}

在这里插入图片描述

http://www.lryc.cn/news/169660.html

相关文章:

  • 已解决 Kotlin Error: Type mismatch: inferred type is String but Int was expected
  • Web应用系统的小安全漏洞及相应的攻击方式
  • git工具下载和安装
  • 腾讯mini项目-【指标监控服务重构】2023-08-04
  • 怎么推广自己抖店的商品?最适合0经验新手操作的办法,来看看
  • 线性代数的本质(三)——线性方程组
  • 轻量级性能测试工具 wrk 如何使用?
  • WebGL 视图矩阵、模型视图矩阵
  • Python 3 – 文件 readline() 方法
  • 如何在微软Edge浏览器上一键观看高清视频?
  • Telegram BoT的主流项目盘点
  • PTA 甲级 1044 Shopping in Mars
  • Linux学习之MyCat实现分库分表
  • DirectX12(d3d12)初始化
  • 算法通关村-----回溯模板如何解决排列组合问题
  • 【1++的C++进阶】之智能指针
  • 一百七十九、Linux——Linux报错No package epel-release available
  • 【AI视野·今日CV 计算机视觉论文速览 第248期】Mon, 18 Sep 2023
  • 解决Vue项目中的“Cannot find module ‘vue-template-compiler‘”错误
  • tensorflow基础
  • spring_注解笔记
  • c++运算符重载
  • vue子组件向父组件传参的方式
  • 代码随想录Day41| 343. 整数拆分 |
  • 工厂模式-(简单工厂模式)
  • V8引擎是如何提升对象属性访问速度的?
  • 彩色相机工作原理——bayer格式理解
  • IDEA中DEBUG技巧
  • 人工智能训练师
  • 【业务功能118】微服务-springcloud-springboot-Kubernetes集群-k8s集群-KubeSphere-OpenELB部署及应用