【Java多线程】关于多线程的一些案例 —— 单例模式中的饿汉模式和懒汉模式以及阻塞队列

简介: 【Java多线程】关于多线程的一些案例 —— 单例模式中的饿汉模式和懒汉模式以及阻塞队列

1、单例模式

对框架和设计模式的简单理解就是,这两者都是“大佬”设计出来的,让即使是一个代码写的不太好的“菜鸡程序员”也能写出还可以的代码。设计模式也可以认为是对编程语言语法的补充。此处提到的“单例模式”就是一种设计模式。


框架(硬性的规定)


设计模式(软性的规定)遵循设计模式,代码的下限就被兜住了,类似下棋时的“棋谱”。


单例,顾名思义,单个实例(对象)。某个类,在一个进程中,只应该创建出一个实例(原则上不应该有多个)。使用单例模式,就可以对代码进行一个更严格的校验和检查。


1.1、饿汉模式

饿汉模式的“创建时机”非常早,实例在类加载的时候就被创建了,相当于程序一启动实例就创建了。因此使用“饿汉”来形容实例创建的迫切,非常早。【并且由于只涉及到读操作,天然的线程安全。】


package thread;
// 期望这个类只能有唯一的实例 (一个进程中)
class Singleton {
    private static Singleton instance = new Singleton();//static修饰的类对象,只存在一个
    public static Singleton getInstance() {   //只提供一个方法获取静态(类属性)实例
        return instance;   //只涉及到读操作,天然的线程安全
    }
    private Singleton() {}   //使用private修饰构造方法,使得无法使用new创建实例
}
public class ThreadDemo26 {
    public static void main(String[] args) {
        // Singleton s = new Singleton();   //无法new
        Singleton s = Singleton.getInstance();
        Singleton s2 = Singleton.getInstance();
        System.out.println(s == s2);   //true
    }
}

在代码中,使用static修饰了一个类对象,然后提供一个方法来获得这个对象,再使用 private 修饰构造方法,使得无法通过 new 创建实例。,由于该实例使用了 static 修饰,在类加载时就已经存在,所以就是懒汉模式。


2.1、懒汉模式

懒汉模式的实例创建时机相比于饿汉模式要更晚,直到第一次使用的时候,才会创建实例。相比“饿汉模式”,“懒汉模式”效率更高。


举个例子:


有一个编辑器想要打开一个10GB的文件,如果按照“饿汉”的方式,编辑器就会先把10GB的数据都加载到内存中,然后再进行统一展示;


如果按照“懒汉”的方式,编辑器就会只读取一小部分数据(比如只读10KB),把10KB先展示出来,随着用户进行翻页等操作,再继续读取后续的数据。


package thread;
// 懒汉的方式实现单例模式.
class SingletonLazy {
    // 这个引用指向唯一实例. 这个引用先初始化为 null, 而不是立即创建实例
    private volatile static SingletonLazy instance = null;   //volatile禁止重排序
    private static Object locker = new Object();
    public static SingletonLazy getInstance() {  //将创建实例的操作放到了getInstance里
        if (instance == null) {   //【注意理解此处的两个if】
            synchronized (locker) {    //考虑线程安全,需要加锁
                if (instance == null) {   //【注意理解此处的两个if】
                    instance = new SingletonLazy();
                }
            }
        }
        return instance;
    }
    private SingletonLazy() { }
}
public class ThreadDemo27 {
    public static void main(String[] args) {
        SingletonLazy s1 = SingletonLazy.getInstance();
        SingletonLazy s2 = SingletonLazy.getInstance();
        System.out.println(s1 == s2);   //true
    }
}

如果 Instance 为 null, 就说明是首次调用, 首次调用就需要考虑线程安全问题, 就要加锁。


如果非 null, 就说明是后续的调用, 就不必加锁了。


讲解第10行和第12行的 if 语句:(双重校验锁)


这样相同且连续的 if 代码从来没写过,这是因为之前写的代码都是在单线程却无阻塞的情况,这种情况下连续两个相同的 if 是无意义的;


但是涉及到阻塞以及多线程的情况,这样的代码就非常的有意义了。看上去是两个一样的条件,实际上这两个条件的结果可能是相反的。


第一个 if 判定的是是否要加锁,如果不是首次调用时就跳过加锁环节,因为此时已经有对象了不需要再创建对象,直接返回即可。


第二个 if 判定的是是否要创建对象。


讲解第6行:(volatile 禁止代码重排序)


讲解第13行:(此处的new 操作又可拆成三个大的步骤,而这三个步骤可能会发生代码重排序。比如步骤1 2 3 =》 1 3 2 ,为了防止这种情况,使用了 volatile)


1、申请一段内存空间


2、在这个内存上调用构造方法,创建出这个实例


3、把这个内存地址赋值给 Instance 引用变量


2、阻塞队列

阻塞队列(BlockingQueue),顾名思义,就是一个队列。阻塞队列是基于普通队列做出的扩展。


基于阻塞队列实现的服务器程序叫消息队列(message queue,mq)


阻塞队列的特点有以下两点:


1、线程安全


2、具有阻塞特性


a)如果针对一个已经满了的队列进行入队列,此时入队列操作就会阻塞,一直阻塞到队列不满(其他线程出队列元素)之后。


b)如果针对一个已经空了的队列进行出队列,此时出队列操作就会阻塞,一直阻塞到队列不空(其他线程入队列元素)之后。


基于阻塞队列,就可以实现“生产者消费者模型”。


1、生产者消费者模式就是通过一个容器来解决生产者和消费者的强耦合问题。



2、削峰填谷,阻塞队列就相当于一个缓冲区,平衡了生产者和消费者的处理能力。【类似于现实中三峡大坝所承担的作用】



类似于擀饺子皮和包饺子的过程,擀饺子皮的线程就是生产者,包饺子的线程是消费者,饺子皮擀好之后放到桌子上,包饺子的线程在从桌子上拿饺子皮包饺子。这里的桌子就是起到了“阻塞队列”的效果,由于桌子的存在,擀饺子皮的线程擀的速度快时,可以把多的饺子皮放到桌子上先(而不需要直接递给包饺子的线程)。


2.1、BlockingQueue 阻塞队列数据结构

Java标准库中提供了现成的阻塞队列数据结构 BlockingQueue,另外还有 ArrayBlockingQueue,LinkedBlockingQueue,PriorityBlockingQueue


package thread;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class ThreadDemo28 {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> queue = new ArrayBlockingQueue<>(100);
        queue.put("aaa");
        String elem = queue.take();
        System.out.println("elem = " + elem);
        elem = queue.take();   //进入阻塞状态
        System.out.println("elem = " + elem);
    }
}

注意:此处的阻塞队列,入队出队操作不再是以前的 offer 和 poll 方法,而是使用带有阻塞功能的 put 和 take 方法。


Hacynn
+关注
目录
打赏
0
0
0
0
13
分享
相关文章
|
9天前
|
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
46 0
Java 多线程创建零基础入门新手指南:从零开始全面学习多线程创建方法
本文从零基础角度出发,深入浅出地讲解Java多线程的创建方式。内容涵盖继承`Thread`类、实现`Runnable`接口、使用`Callable`和`Future`接口以及线程池的创建与管理等核心知识点。通过代码示例与应用场景分析,帮助读者理解每种方式的特点及适用场景,理论结合实践,轻松掌握Java多线程编程 essentials。
98 5
Java 多线程最新实操技术与应用场景全解析:从基础到进阶
本文深入探讨了Java多线程的现代并发编程技术,涵盖Java 8+新特性,如CompletableFuture异步处理、Stream并行流操作,以及Reactive编程中的Reactor框架。通过具体代码示例,讲解了异步任务组合、并行流优化及响应式编程的核心概念(Flux与Mono)。同时对比了同步、CompletableFuture和Reactor三种实现方式的性能,并总结了最佳实践,帮助开发者构建高效、扩展性强的应用。资源地址:[点击下载](https://pan.quark.cn/s/14fcf913bae6)。
118 3
Java多线程基础
本文主要讲解多线程相关知识,分为两部分。第一部分涵盖多线程概念(并发与并行、进程与线程)、Java程序运行原理(JVM启动多线程特性)、实现多线程的两种方式(继承Thread类与实现Runnable接口)及其区别。第二部分涉及线程同步(同步锁的应用场景与代码示例)及线程间通信(wait()与notify()方法的使用)。通过多个Demo代码实例,深入浅出地解析多线程的核心知识点,帮助读者掌握其实现与应用技巧。
深入理解Java并发编程:线程安全与性能优化
【2月更文挑战第22天】在Java并发编程中,线程安全和性能优化是两个重要的主题。本文将深入探讨这两个主题,包括线程安全的基本概念,如何实现线程安全,以及如何在保证线程安全的同时进行性能优化。
96 0
深入理解Java并发编程:线程安全与锁机制
【5月更文挑战第31天】在Java并发编程中,线程安全和锁机制是两个核心概念。本文将深入探讨这两个概念,包括它们的定义、实现方式以及在实际开发中的应用。通过对线程安全和锁机制的深入理解,可以帮助我们更好地解决并发编程中的问题,提高程序的性能和稳定性。
解锁Java并发编程奥秘:深入剖析Synchronized关键字的同步机制与实现原理,让多线程安全如磐石般稳固!
【8月更文挑战第4天】Java并发编程中,Synchronized关键字是确保多线程环境下数据一致性与线程安全的基础机制。它可通过修饰实例方法、静态方法或代码块来控制对共享资源的独占访问。Synchronized基于Java对象头中的监视器锁实现,通过MonitorEnter/MonitorExit指令管理锁的获取与释放。示例展示了如何使用Synchronized修饰方法以实现线程间的同步,避免数据竞争。掌握其原理对编写高效安全的多线程程序极为关键。
147 1
Java并发编程中的线程安全问题及解决方法
在Java编程中,线程安全是一个至关重要的问题,特别是在并发编程中。本文将探讨Java并发编程中常见的线程安全问题,包括数据竞争、死锁和内存可见性,并介绍了相应的解决方法,如使用同步锁、并发容器和原子类等技术,以确保多线程环境下程序的正确性和性能。
147 29
Java一分钟之-并发编程:线程安全的集合类
【5月更文挑战第19天】Java提供线程安全集合类以解决并发环境中的数据一致性问题。例如,Vector是线程安全但效率低;可以使用Collections.synchronizedXxx将ArrayList或HashMap同步;ConcurrentHashMap是高效线程安全的映射;CopyOnWriteArrayList和CopyOnWriteArraySet适合读多写少场景;LinkedBlockingQueue是生产者-消费者模型中的线程安全队列。注意,过度同步可能影响性能,应尽量减少共享状态并利用并发工具类。
119 2
Java并发编程中的线程安全问题及解决方案探讨
在Java编程中,特别是在并发编程领域,线程安全问题是开发过程中常见且关键的挑战。本文将深入探讨Java中的线程安全性,分析常见的线程安全问题,并介绍相应的解决方案,帮助开发者更好地理解和应对并发环境下的挑战。【7月更文挑战第3天】
221 0
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问