Java多线程_阻塞队列

1.什么是阻塞队列
       我们知道,PriorityQueue、LinkedList这些都是非阻塞队列。在我们使用非阻塞队列的时候有一个很大问题,它不会对当前线程产生阻塞,那么在面对类似消费者-生产者的模型时,就必须额外地实现同步策略以及线程间唤醒策略,这个实现起来就非常麻烦。但是有了阻塞队列就不一样了,它会对当前线程产生阻塞,比如一个线程从一个空的阻塞队列中取元素,此时线程会被阻塞直到阻塞队列中有了元素。当队列中有元素后,被阻塞的线程会自动被唤醒(不需要我们编写代码去唤醒)。这样提供了极大的方便性。

2.阻塞队列的种类
         阻塞队列本质上就是队列,它主要有一下几种:

  • ArrayBlockingQueue:基于数组实现的阻塞队列,先进先出队列,有界队列。在创建时必须制定容量大小。并可以指定公平性与非公平性,默认情况下是非公平的,即不保证等待时间最长的队列最优先能够访问队列。
  • LinkedBlockingQueue:基于链表实现的阻塞队列,先进先出队列,有界队列。在创建时如果不指定容量大小,则默认大小为Integer.MAX_VALUE。
  • PriorityBlockingQueue:按照元素的优先级对元素进行排序,按照优先级顺序出队。并且该阻塞队列为无界阻塞队列,即容量没有上限(源码中它没有容器满的信号标志)。
  • DelayQueue:基于PriorityQueue的延时阻塞队列,无界队列。DelayQueue中的元素只有当其指定的延迟时间到了,才能够从队列中获取到该元素。因为DelayQueue是一个无界队列,所以往队列中插入数据的操作永远不会被阻塞,而只有获取数据的操作才会被阻塞。
  • SynchronousQueue:一个不存储元素的阻塞队列。
  • LinkedTransferQueue:一个由链表结构组成的无界阻塞队列。
  • LinkedBlockingDeque:一个由链表结构组成的双向阻塞队列。

3.阻塞队列中的几个主要方法

  •        put方法用来向队尾存入元素,如果队列满,则等待;
  •   take方法用来从队首取元素,如果队列为空,则等待;
  •   offer方法用来向队尾存入元素,如果队列满,则等待一定的时间,当时间期限达到时,如果还没有插入成功,则返回false;否则返回true;
  •   poll方法用来从队首取元素,如果队列空,则等待一定的时间,当时间期限达到时,如果取到,则返回null;否则返回取得的元素;

4.使用(以LinkedBlockingQueue为例)

 

import java.util.concurrent.LinkedBlockingQueue;public class BlockingQueueDemo {int size = 10;LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<>(size);public static void main(String[] args) {BlockingQueueDemo bqd = new BlockingQueueDemo();Consumer c = bqd.new Consumer();Productor p = bqd.new Productor();c.setName("消费者");p.setName("生产者");c.start();p.start();}class Consumer extends Thread {@Overridepublic void run() {consume();}private void consume() {while (true) {try {queue.take();} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "消费了一个物品,还有" + queue.size() + "个物品");}}}class Productor extends Thread {@Overridepublic void run() {product();}private void product() {while (true) {try {queue.put(1);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName() + "生产了一个物品,现有" + queue.size() + "个物品");}}}
}

 

转载于:https://www.cnblogs.com/ericz2j/p/10283533.html

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

CMake 入门与进阶

目录cmake简介cmake的下载cmake 的使用方法示例一&#xff1a;单个源文件(cmake生成的中间文件以及可执行文件都放在build目录下)示例二&#xff1a;多个源文件示例三&#xff1a;生成库文件(动态库和静态库、修改库文件名字、最低版本要求)示例四&#xff1a;将源文件放到不同…

nunit 2.2.3 released, 支持vs2005 和.net 2.0了.

主要是提供对vs 2005 及.net 2.0的支持&#xff0c;同时修正了一些bug&#xff0e;对于没有使用vs team suite的人而言&#xff0c;可以将nunit集成到vs 2005 professional了&#xff0e;http://sourceforge.net/projects/nunit转载于:https://www.cnblogs.com/margiex/archive…

【UOJ#246】套路(动态规划)

【UOJ#246】套路&#xff08;动态规划&#xff09; 题面 UOJ 题解 假如答案的选择的区间长度很小&#xff0c;我们可以做一个暴力\(dp\)计算\(s(l,r)\)&#xff0c;即\(s(l,r)min(s(l1,r),s(l,r-1),abs(a_r-a_l))\)。 我们发现\(s(l,r)\le \frac{m}{r-l1}\)&#xff0c;那么当长…

将对象集合包装成JSON格式

import java.lang.reflect.Field; import java.lang.reflect.Method; import java.util.ArrayList; import java.util.List; import com.jssh.bean.system.SysMenu; import com.jssh.bean.system.SysMenuId; public class JsonUtil<T> {/*** 将对象集合包装成JSON格式* p…

.Net应用之数据连接(少儿助学网MisDataSet.dll)原代码

原代码文件下载 :MisDataSet数据连接字符串放置在web.config文件中如下:<?xml version"1.0" encoding"utf-8" ?><configuration> <appSettings> <add key "SQLCONNECTIONSTRING" value "data source . ; uid…

Linux开发板网线直连电脑配置方法/vmware虚拟机与本机的网络ping通

目录Linux开发板网线直连电脑配置方法vmware虚拟机与本机的网络ping通Linux开发板网线直连电脑配置方法 参考&#xff1a;https://www.bilibili.com/video/BV1n541197rk?spm_id_from333.999.0.0 一般情况&#xff0c;开发板连路由器&#xff0c;电脑也连路由器&#xff0c;路由…

ubuntu网站做图像外链

http://paste.ubuntu.org.cn 转载于:https://www.cnblogs.com/yuliyang/p/3658964.html

Markdown 基础学习

Markdown是什么&#xff1f; Markdwon是一种轻量级标记语言&#xff0c;它以纯文本形式&#xff08;易读、易写、易更改&#xff09;编写文档&#xff0c;并最终以HTLM格式发布。Markdown也可以理解为将以 MARKDOWN语法编写的语言转换成HTML内容的工具。 为什么要使用Markdown?…

黑暗精灵崔斯特系列小说

[资料]黑暗精灵崔斯特系列小说 转自群星论坛&#xff1a; The complete Drizzts saga 崔斯特传奇完全列表 1、Realms of Magic《魔法国度》 作者&#xff1a;Brian Thomsen, Fred Fields 1995年12月出版 三星半 相关内容&#xff1a;短篇“Guenhwyvar"&#xff0c;关…

状态机模型

参考&#xff1a;什么是状态机&#xff1f;用C语言实现进程5状态模型 参考&#xff1a;设计模式&#xff1a;一目了然的状态机图 案例&#xff1a;状态模式(C语言实现)——MP3播放、暂停案例 STM32按键消抖——入门状态机思维&#xff08;常用的switch-case形式&#xff0c;实现…

yii开启gii功能

如果不想面对黑白界面&#xff0c;那么yii框架&#xff0c;给我们提供了一个模块gii 在配置文件中main.php 再通过访问模块的方式访问gii转载于:https://www.cnblogs.com/xiashuo-he/p/3659334.html

2、基于wsgiref模块DIY一个web框架

一 web框架 Web框架(Web framework)是一种开发框架&#xff0c;用来支持动态网站、网络应用和网络服务的开发。这大多数的web框架提供了一套开发和部署网站的方式&#xff0c;也为web行为提供了一套通用的方法。web框架已经实现了很多功能&#xff0c;开发人员使用框架提供的方…

C标准时间与时间戳的相互转换

什么是时间戳&#xff1f; 时间戳是指格林威治时间自1970年1月1日&#xff08;00:00:00 GTM&#xff09;至当前时间的总秒数。它也被称为Unix时间戳&#xff08;Unix Timestamp&#xff09;。时间戳是能够表示一份数据在一个特定时间点已经存在的完整的可验证的数据&#xff0…

打招呼九句

只要是朋友都能用的&#xff1a;Hows everything? 一切都好&#xff1f; Whats up? 近况如何&#xff1f; Whats new? 有什么新鲜事&#xff1f; Whats happening? 在忙什么&#xff1f; 任何时后都可以用&#xff0c;但比较见外: How are you? 你好吗&#xff1f; 适…

mysql开启慢查询方法(转)

1&#xff0c;配置开启 Linux: 在mysql配置文件my.cnf中增加 log-slow-queries/var/lib/mysql/slowquery.log (指定日志文件存放位置&#xff0c;可以为空&#xff0c;系统会给一个缺省的文件host_name-slow.log) long_query_time2 (记录超过的时间&#xff0c;默认为10s) log…

windows生成dump文件

windows下程序有时突然崩溃了&#xff0c;偶发性的崩溃很难找。于是就需要保存崩溃时的dump信息了。 下面是关于如何生成dmp文件的代码。 头文件 #pragma once #include <windows.h> #include <DbgHelp.h> #include <stdlib.h> #include <string> #pra…

Linux系统信息与系统资源

目录系统信息系统标识unamesysinfo 函数gethostname 函数sysconf()函数时间、日期GMT 时间UTC 时间UTC 时间格式时区实时时钟RTC获取时间time/gettimeofday时间转换函数设置时间settimeofday总结进程时间times 函数clock 函数产生随机数休眠(延时)秒级休眠: sleep微秒级休眠: u…

关于Qomo OpenProject的进度(2006.01.04)

目前项目仍在初起阶段。许多事情是我一个人来做的&#xff0c;因此时间上实在不够用。我目前的主要工作是撰写项目的相关文档和整理项目中的可公开代码。我需要从原有的WEUI项目中剥离出一些非商业的代码出来。——尽管这个工作不复杂&#xff0c;但涉及到原公司的授权问题。由…

Java Web会话管理

一.Cookie会话 cookie技术会话数据会保存在浏览器客户端 cookie技术核心: 1.构造cookie对象 2.设置cookie&#xff1a;有效访问时间(setMaxAge)&#xff0c;有效访问路径(setPath)&#xff0c;设置cookie的值(setValue) 3.发送cookie到客户端保存&#xff1a;response.addCooki…

简单的一个用javascript做的'省市区'三级联动效果

2019独角兽企业重金招聘Python工程师标准>>> <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> <html> <head><title>javascript简单三级联动效果</title…