【JavaEE】多线程代码实例：单例模式与阻塞队列BlockingQueue

目录

单例模式：

什么是单例模式？ 

单例模式的实现方式： 

饿汉模式： 

懒汉模式： 

基于并发编程对单例模式线程安全问题的讨论： 

阻塞队列：

标准库中的阻塞队列： 

自实现阻塞队列： 

生产者消费者模型： 

生产者消费者模型的实现： 

利用系统的BlockingQueue实现生产者消费者模型：

利用自实现的BlockingQueue实现生产者消费者模型：

---

 

单例模式：

什么是单例模式？ 

单例模式能保证某个类只能存在唯一的实例，不能创建多个实例。这种设计模式是需要在特定业务场景进行使用的。

单例模式的实现方式： 

单例模式的实现方式有很多种，主要的方式是饿汉模式和懒汉模式。 

饿汉模式： 

懒汉模式的简单实现：

//单例模式：饿汉模式class Singleton{//第一步实例化对象public static Singleton singleton=new Singleton();//构造方法为空private Singleton(){}//获取对象实例public static Singleton getInstance(){return  singleton;}
}public class ThreadDemo4 {public static void main(String[] args) {//Singleton singleton1=new Singleton();无法创建对象！！！//验证单一性：Singleton singleton1=Singleton.getInstance();Singleton singleton2=Singleton.getInstance();System.out.println(singleton1==singleton2);}
}

通过比较我们发现得到的实例是同一个实例，且在该模式下不能再进行实例的创建。从代码我们可以知道，该模式实例的创建要比一般类的实例创建要早，所以我们形象的称为饿汉模式（饿的等不及了），该对象的实例在类加载阶段就进行了创建。

饿汉模式如何确保创建对象是单例的？类定义时创建静态对象+私有构造方法，公开接口get实例，并且设置成静态确保可利用类名直接调用。 

懒汉模式： 

懒汉模式之所以被称为这样也是很形象的说法，这种模式下的单例模式，只有在需要实例的时候才会进行创建实例，并且只会创建这一次。

懒汉模式简单实现：

class Singleton1{public static Singleton1 singleton1=null;//先为空//同样构造方法私有化private Singleton1(){}//懒汉模式是在获取对象实例的方法中进行创建实例的public static Singleton1 getSingleton1() {if(singleton1==null){singleton1=new Singleton1();}return singleton1;}
}public class ThreadDemo5 {public static void main(String[] args) {//Singleton1 singleton1=new Singleton1();无法创建实例Singleton1 s1=Singleton1.getSingleton1();Singleton1 s2=Singleton1.getSingleton1();System.out.println(s1==s2);}
}

  

很显然，我们的实例是在第一次获取实例的时候进行创建的。 

懒汉模式是通过创建静态对象变量+需要时创建对象+提供公开的接口并且设置成静态方法，私有化构造方法实现的。

这里需要注意：上述的单例模式在单线程的模式下运行时没有安全问题的，但是放到并发编程中就会出现问题！！！

基于并发编程对单例模式线程安全问题的讨论： 

 我们可以看到：在饿汉模式下，我们一上来就把对象实例化了，在多线程当中只会有读的操作，所以不会出现线程安全问题，所以我们说饿汉模式下的单例模式是线程安全的。但是对于懒汉模式而言，在获取实例的时候创建了实例，这样就即涉及到读，又涉及到写的操作了。

线程安全问题发生在首次创建实例时. 如果在多个线程中同时调用 getInstance 方法, 就可能导致
创建出多个实例.一旦实例已经创建好了, 后面再多线程环境调用 getInstance 就不再有线程安全问题了(不再修改singleton1 了)
所以使用synchronized可以改善这里的线程安全问题

懒汉模式多线程改进1.0版本：

class Singleton1{public static Singleton1 singleton1=null;//先为空//同样构造方法私有化private Singleton1(){}//懒汉模式是在获取对象实例的方法中进行创建实例的public synchronized static Singleton1 getSingleton1() {if(singleton1==null){singleton1=new Singleton1();}return singleton1;}
}

但是，你以为这样就结束了吗？NO！！！

这里面还有一些问题！比如锁竞争，内存可见性问题等等。加锁 / 解锁是一件开销比较高的事情。 而懒汉模式的线程不安全只是发生在首次创建实例的时候。因此后续使用的时候, 不必再进行加锁了。所以我们考虑使用一个if判定下看当前是否已经把singleton1实例创建出来了。同时为了避免 "内存可见性" 导致读取的singleton1出现偏差, 于是补充上volatile。当多线程首次调用getInstance, 大家可能都发现instance为null, 于是又继续往下执行来竞争锁,其中竞争成功的线程, 再完成创建实例的操作。当这个实例创建完了之后, 我们还需要用一个if来判断是否创建完毕了，如果创建完毕了，其他竞争到锁的线程就被该层的if 挡住，也就不会继续创建其他实例。

所以我们将对懒汉模式进行二次改进：

懒汉模式多线程改进2.0版本：

class Singleton1{public volatile static Singleton1 singleton1=null;//先为空//同样构造方法私有化private Singleton1(){}//懒汉模式是在获取对象实例的方法中进行创建实例的public  static Singleton1 getSingleton1() {if(singleton1==null){synchronized (Singleton1.class){if(singleton1==null){singleton1=new Singleton1();}}}return singleton1;}
}

这样我们的懒汉模式才算是完善了。

以下代码在加锁的基础上, 做出了进一步改动:
使用双重 if 判定, 降低锁竞争的频率，给singleton1加上了 volatile
我们举个例子：

1) 有三个线程, 开始执行getInstance, 通过外层的if (singleton1 == null) 知道了实例还没有创建的消息，于是开始竞争同一把锁
2) 其中线程1率先获取到锁, 此时线程1通过里层的if (singleton1 == null) 进一步确认实例是否已经创建，如果没创建, 就把这个实例创建出来
3) 当线程1释放锁之后, 线程2和线程3也拿到锁, 也通过里层的 if (singleton1 == null) 来确认实例是否已经创建, 发现实例已经创建出来了, 就不再创建了
4) 后续的线程, 不必加锁, 直接就通过外层if (singleton1 == null) 就知道实例已经创建了, 从而不再尝试获取锁了，降低了开销
试着理解一下吧。

阻塞队列：

阻塞队列是一种特殊的队列，也遵守 "先进先出" 的原则。
阻塞队列能是一种线程安全的数据结构, 并且具有以下特性:
当队列满的时候, 继续入队列就会阻塞, 直到有其他线程从队列中取走元素。
当队列空的时候, 继续出队列也会阻塞, 直到有其他线程往队列中插入元素。
阻塞队列的一个典型应用场景就是 "生产者消费者模型". 这是一种非常典型的开发模型 

标准库中的阻塞队列： 

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

标准库中提供了实现阻塞队列功能的类和接口。虽然说，阻塞队列本质上还是一个队列，也就是说实现了Queue接口，也有普通队列方法，但是我们使用阻塞队列主要使用的不是这些，而是它特有的阻塞功能，此时对应的入队和出队操作的方法分别对应的是put和take方法。

同时BlockingQueue还有这些比较常用的实现Queue接口的类，背后的数据结构看名字就知道是什么了。此外，后面是Deque的是双端阻塞队列。 

注意点：

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

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;public class BlockingQueueDemo1 {public static void main(String[] args) throws InterruptedException {//阻塞队列BlockingQueue<String> queue=new LinkedBlockingQueue<>();//入队列queue.put("abc");//出队列，如果没有就进行阻塞String elem=queue.take();System.out.println(elem);}
}

在阻塞队列中，如果队列放满了或者没有出的元素都会进入阻塞状态。这里演示一下没有元素的情况：

 此时队列中没有元素，程序进行了阻塞。

自实现阻塞队列： 

 实现阻塞队列的关键在于实现其阻塞的功能。其他的和普通的队列差不多。这里主要实现put和take方法：

class MyBlockingQueue{//利用数组实现private int[] arr=new int[1000];//设定数组长度为1000private int size=0;//记录数组的内容长度//利用end和begin两个指针使得数组变为循环数组（逻辑上的循环）private int end=0;private int begin=0;//实现put方法//阻塞考虑使用wait和notify进行唤醒（sleep不太靠谱）public void put(int value) throws InterruptedException {//判断是否满了（这里要用循环判断，因为在多线程当中，线程被唤醒的时候不一定不满）//加锁保证原子性synchronized (this){while(size>= arr.length){this.wait();}//不满之后放入元素arr[end]=value;//调整长度end++;size++;//如果放满了则将end变为0if(end>= arr.length){end=0;}//进行唤醒this.notify();}}//实现take方法public int take() throws InterruptedException {synchronized (this){//判断是否为空while (size==0){this.wait();}//不空之后开始取出元素int ret=arr[begin];begin++;if(begin>= arr.length){begin=0;}size--;this.notify();return ret;}}//长度public synchronized int Size(){return size;}}public class BlockingQueueDemo3 {public static void main(String[] args) throws InterruptedException {MyBlockingQueue queue=new MyBlockingQueue();queue.put(100);queue.put(200);queue.put(300);System.out.println(queue.take());System.out.println(queue.take());System.out.println(queue.take());}
}

 

 显然，当其中没有元素的时候就会阻塞等待。 

生产者消费者模型： 

生产者消费者模式就是通过一个容器来解决生产者和消费者的强耦合问题。
生产者和消费者彼此之间不直接通讯，而通过阻塞队列来进行通讯，所以生产者生产完数据之后不用等待消费者处理，直接扔给阻塞队列，消费者不找生产者要数据，而是直接从阻塞队列里取。

首先，阻塞队列相当于一个缓冲区，它平衡了生产者和消费者之间的处理能力。

其次，阻塞队列使得生产者和消费者之间的进行了解耦合，也就是消费者不再是直接依赖生产者。

对于阻塞队列，生产者是添加元素的一方，消费者是取元素的一方，产品是阻塞队列的元素。生产者和消费者通过阻塞队列相互联系。

画个图演示一下：

我们举向游戏里面氪金的例子吧！！！

这样就会出现一个问题：服务器A和服务器B的耦合太高，一旦其中一个服务器出现了问题，就会导致另一个服务器也无法完成需求。就会出现一个服务器挂了，把另一个服务器也带走的情况。

并且，如果我们需要在此基础上加一个新的服务器参与其他相关的功能，比如日志，也是会有问题的！

那么如何解决这种情况呢？这就用到了当前的生产者消费者模型。生产者生成的资源，我们可以将其放到一个阻塞队列当中去，当有消费者需要消费的时候，就直接从该阻塞队列当中去取，如果队列中没有资源，就阻塞等待，等待生产者进行生产，当阻塞队列满的时候，生产者也要进行阻塞等待。这里的服务器A就是生产者，服务器BC就是消费者。所以我们可以利用该模型进行这样的设计：

生产者消费者模型的实现： 

利用系统的BlockingQueue实现生产者消费者模型：

首先我们利用系统提供的BlockingQueue实现生产者消费者模型： 

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;public class BlockingQueueDemo2 {public static void main(String[] args) {//创建阻塞队列BlockingQueue<Integer>queue=new LinkedBlockingQueue<>();//使用两个线程：一个线程充当生产者，一个线程充当消费者//生产者Thread t1=new Thread(()->{int count=0;while(true){try {queue.put(count);System.out.println("生产者生产："+count);count++;Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});Thread t2=new Thread(()->{while(true){try {int ret=queue.take();System.out.println("消费者消费："+ret);Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});t1.start();t2.start();}
}

 

我们可以明确的看到，消费元素和生产元素是成对出现的。这就不会出现生产者没有生产出来的东西被消费的情况。 

利用自实现的BlockingQueue实现生产者消费者模型：

class MyBlockingQueue1{//利用数组实现private int[] arr=new int[1000];//设定数组长度为1000private int size=0;//记录数组的内容长度//利用end和begin两个指针使得数组变为循环数组（逻辑上的循环）private int end=0;private int begin=0;//实现put方法//阻塞考虑使用wait和notify进行唤醒（sleep不太靠谱）public void put(int value) throws InterruptedException {//判断是否满了（这里要用循环判断，因为在多线程当中，线程被唤醒的时候不一定不满）//加锁保证原子性synchronized (this){while(size>= arr.length){this.wait();}//不满之后放入元素arr[end]=value;//调整长度end++;size++;//如果放满了则将end变为0if(end>= arr.length){end=0;}//进行唤醒this.notify();}}//实现take方法public int take() throws InterruptedException {synchronized (this){//判断是否为空while (size==0){this.wait();}//不空之后开始取出元素int ret=arr[begin];begin++;if(begin>= arr.length){begin=0;}size--;this.notify();return ret;}}//长度public synchronized int Size(){return size;}}public class BlockingQueueDemo4 {public static void main(String[] args) throws InterruptedException {MyBlockingQueue1 queue1=new MyBlockingQueue1();//生产者Thread producer =new Thread(()->{int count=0;while(true){try {queue1.put(count);System.out.println("生产者生产元素："+count);count++;Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});//消费者Thread customer =new Thread(()->{while(true){try {int ret=queue1.take();System.out.println("消费者消费元素："+ret);Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});producer.start();customer.start();}
}