如果做网站,阿里巴巴国际站做2个网站有用吗,如何查看网站空间,专业企业网站设计服务公司目标#xff1a; 1. 认识与使用阻塞队列 2. 认识与实现消费者模型 目录
阻塞队列的特点
生产者消费者模型
生产者消费者模型的优点
阻塞队列实现该模型 阻塞队列的特点
1. 线程安全
2. 带有阻塞特性 #xff08;1#xff09;如果队列为空#xff0c;继续出队列 1. 认识与使用阻塞队列 2. 认识与实现消费者模型 目录
阻塞队列的特点
生产者消费者模型
生产者消费者模型的优点
阻塞队列实现该模型 阻塞队列的特点
1. 线程安全
2. 带有阻塞特性 1如果队列为空继续出队列就会发生阻塞。直到其他线程往队列里添加元素 2如果队列为满继续入队列就会发生阻塞。直到其他线程从队列里取走元素
java库的阻塞队列
1. BlockingDeque为抽象类不能直接newjava库中提供了 数组 和 链表的方式实现
2. 阻塞队列继承与Queue要是想实现阻塞特性使用 put() 和 take() 方法 生产者消费者模型
以包饺子为例子流程一般为和面擀饺子皮包饺子。我擀饺子皮另外的人负责包饺子消耗饺子。这种工作模式就是生产者-消费者模型。
但是我生产的饺子皮放到哪呢一般是放到 盖帘 上就相当于阻塞队列。我擀饺子皮慢的话另外的人就得等着我擀好再包饺子。从空的队列中获取元素时阻塞我擀饺子皮快的话 盖帘上 满了 我就得等待往满的队列里添加元素也会堵塞。 生产者消费者模型的优点
1. 解耦合 两个模块联系越紧密耦合就越高。 比如实现一个简单的分布式系统 客户端向A服务器发送请求但是这个请求也得从A传到BB再返回给A才能返回响应到客 户这下A和B有着高耦合B出现问题可能对A会有影响。 相比之下使用生产者消费者模型在A和B之间封装一个阻塞队列让A传给这个阻塞队列 再传给B这下就降低了A与B的耦合B出现问题对A没有影响。
2. 削峰填谷 峰短时间内请求量多的 谷短时间内请求量比较少 以上一个为例子如果客户端传给A的数据比较多则B也就会有很多数据。可能会出现问 题B不能直接承受这么多的数据 先比之下 使用生产者消费者模型在A和B之间封装一个阻塞队列让A传给这个阻塞队列 再传给B在B所能承受的范围内多余的先存放到队列中这下B就不会挂了。 阻塞队列实现该模型
在这里生产者和消费者我们使用两个线程来表示。
1. 生产者生产的慢消费的快
public class Tset {public static void main(String[] args) {BlockingDequeString queue new LinkedBlockingDeque(1000);//生产者Thread t1 new Thread(() - {int num 1;while (true) {try {queue.put(num );System.out.println(生产元素 num);Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});//消费者Thread t2 new Thread(() - {while (true) {try {String result queue.take();System.out.println(消费元素 result);} catch (InterruptedException e) {throw new RuntimeException(e);}}});t1.start();t2.start();}
}
2. 生产者生产的快消费的慢
public class Tset {public static void main(String[] args) {BlockingDequeString queue new LinkedBlockingDeque(1000);//生产者Thread t1 new Thread(() - {int num 1;while (true) {try {queue.put(num );System.out.println(生产元素 num);} catch (InterruptedException e) {throw new RuntimeException(e);}}});//消费者Thread t2 new Thread(() - {while (true) {try {String result queue.take();System.out.println(消费元素 result);Thread.sleep(500);} catch (InterruptedException e) {throw new RuntimeException(e);}}});t1.start();t2.start();}
}
