jdk8之SynchronousQueue学习之非公平队列

SynchronousQueue是一个无存储空间的阻塞队列,是实现newFixedThreadPool的核心,它也分为公平和非公平,因为是无存储空间的,所以与其他阻塞队列实现不同的是,这个阻塞peek方法直接返回null,无任何其他操作,其他的方法与阻塞队列的其他方法一致。这个队列的特点是,必须先调用take或者poll方法,才能使用off,add方法,下面看源码级实现。


类关系结构图

从构造函数来看,底层是一个Transfer对象,公平的阻塞队列使用的是TransferQueue实现,非公平使用的是TransferStack实现。

这个队列方法的实现基本都是调用Transfer的实现的方法。

这里面request是代表消费者,data是代表生产者,而FULFILING是拥来判断当前队列是否有request,如果有则生产者数据进来才能被消费掉,不然直接返回null

同时保存了一个表示栈顶的一个snode对象

先来看看take和poll方法,里面调用的是transferer方法,第一个参数决定了是生产者还是消费者,第二个参数用于判断是否阻塞一端时间,第三个参数阻塞时长。如果是消费者,则会返回消费者数据本身,如果返回的是null,则直接通过抛出异常方式来终止线程

一进来首先通过第一个参数用来判断是生产者还是消费者。用来阻塞的对象是Snode这个对象

SNode对象里面第一个是链指向下一个snode,match则保存的是与之匹配的对方角色,比如如果snode是生产者,则会保存一个消费者,然后这两个凑成一对返回。第三个线程是保存的当前线程,用来控制park和unpark的,因为我们知道,park和unpark是基于一个线程的,也就是说对线程a调用了park后,只能通过对线程a调用unpark才能释放掉a线程,第四个对象item保存的是数据,第五个Mode是拥来保存区别是生产者还是消费者的

首先拿到head,这里的head对象代表着栈顶的一个等待消费者,如果为null,或者如果不为null,则判断数据身份是否一致(是否为生产者或者消费者),如果一致则继续判断是否需要阻塞等待,如果不阻塞等待,或者阻塞等待,但是阻塞时间还没有到,则先把当前请求的对象包装为一个snode,然后通过CAS压入栈顶。这里封装的时候,第一个参数用来判断当前s是否被包装,如果已经被包装则直接执行替换操作,如果未被包装则直接new一个Snode,然后在进行赋值,这里主要是赋值是生产者还是消费者,第二个赋值是指向当前栈顶的元素,然后返回,用CAS压入栈顶。接下来调用awaitFulfill方法进行自旋,这里自旋会根据系统CPU核数,如果是2核以上,则自旋16*32,如果不是则直接调用park把当前线程挂起。

如下图所示,不停调用take或者poll方法入栈是下面这样一个过程

下面是awaitFull方法的源码,通过shouldSpin来进行判断是否需要自旋,自旋的条件是这个node在当前的栈顶。或者不在栈顶判断是否可以请求或者消费数据。

自旋计数是通过下面的spins=shouldSpin(s)?(spins-1):0来完成的。如果自旋结束了最后先保存当前线程到snode对象里面去,然后调用park命令挂起。这样就完成了消费者入队。

下面我们看请求数据,offer方法,这下面也是调用了transfer方法

代码和上面take方法调用的是一个方法。这里通过第二行就完成了判断是一个消费者。然后如果栈里没有等待的消费者,则直接就返回了Null,而如果有等待的生产者,则会跳到下面的判断调用isFulfilling方法,这个方法通过比较mode来判断是否可以消费。

如果可以,则把当前对象包装为一个snode,然后压入栈顶,然后如果压入的生产者下一个节点为null,说明没有消费者,然后就直接把所有的重新置为null,中断循环。如果有的话,则继续拿到消费者的下一个消费者。举例比如栈中有1,2,3消费者,然后新来的生产者s(a)压入栈顶,然后a的下一个指向(m)1,这时候呢(mn)指向了2,这是因为生产者a和消费者1要同步出栈,然后就把2推到了栈顶。这里调用(m)1的tryMatch,并传入了s(a),

这里很简单,一进来时候进来的是(m)1的对象内部,这时候match肯定是null,之前没有设置过,这时候就把这个match替换为生产者(s),然后拿到阻塞的线程,调用unpark方法释放线程。然后返回true。如果不为Null则判断这个消费者里面保存的生产者是否是传入进来的生产者。

如果匹配成功,则直接把(mn)2推到栈顶,然后返回请求的数据。如果不匹配则向栈的下层去寻找,直到找到为止。

如下所示,a代表生产者,1 2 3代表消费者,这样就完成了一次请求。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,386评论 6 479
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,939评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,851评论 0 341
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,953评论 1 278
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,971评论 5 369
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,784评论 1 283
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,126评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,765评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,148评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,744评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,858评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,479评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,080评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,053评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,278评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,245评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,590评论 2 343

推荐阅读更多精彩内容

  • 从三月份找实习到现在,面了一些公司,挂了不少,但最终还是拿到小米、百度、阿里、京东、新浪、CVTE、乐视家的研发岗...
    时芥蓝阅读 42,183评论 11 349
  • 一、多线程 说明下线程的状态 java中的线程一共有 5 种状态。 NEW:这种情况指的是,通过 New 关键字创...
    Java旅行者阅读 4,655评论 0 44
  • 相关概念 面向对象的三个特征 封装,继承,多态.这个应该是人人皆知.有时候也会加上抽象. 多态的好处 允许不同类对...
    东经315度阅读 1,925评论 0 8
  • 本科从关系角度阐述了为什么智商高的人情商往往不高。 天才,一般都会沉浸在自我意识中,很少顾忌别人的感受。这样的人却...
    w小郭阅读 156评论 1 0
  • 感情的道路上屡屡受挫。我不开心了 来自外向的孤独患者。
    一粒小草莓阅读 298评论 0 0