4.并发基础构建模块1

将线程安全性委托给线程安全类。

java早期的vector hashtable

<b>jdk1.2出的Collections.synchronizedXXX,就是用组合的形式把一般的集合容器类包装成了线程安全容器,其效果和vector和hashtable等差不多</b>

  • 线程安全容器还是有许多常用操作没有覆盖:

a) 迭代器:遍历所有元素

for(int i=0; i < vector.size();i++){ // 不安全的迭代器
    dosomething(vector.get(i));
}

b) putIfAbsent等先检查后执行
c) 获取集合最后一个元素(先计算size,再获取size-1那个索引下的元素)

此时,需要调用客户端额外再加锁.

private Object getLast(Vector list){
   synchronized(list){ //使用list对象作为锁,保证锁一致,因为Vector就是以对象内置锁来保证同步的
      int last = list.size()-1;
      return list.get(last);
   }
}
}
  • 迭代过程中的ConcurrentModificationException

当元素新增或删除时,迭代过程中会直接跑出该异常(fail-fast,及时抛出错误)。
Vector,ArrayList等集合都有一个modCount字段,特别注意该字段不是volatile类型的,所以这个fail-fast机制并不能保证每次的修改对迭代器都可见,非常弱的机制(主要是为了保证迭代器的迭代性能).
所以,为了避免这个问题,在每次迭代前可以看集合元素的量或者拷贝是不是特别复杂,量不大也不复杂就迭代前先copy一份出来迭代。

当然,直接对容器加锁进行迭代也是可以的,不过风险很大!死锁,性能都有问题。

  • 要特别注意容器的一些容易忽视的操作:toString, equals,hashCode!!它们很有可能会隐式调用容器的迭代器!

jdk5 concurrent容器(这是并发容器(高大上!!吞吐量效率都叼得多),vector,hashtable是同步容器)

如ConcurrentHashMap,CopyOnWriteList(主要针对主要用作迭代的集合),Queue, BlockingQueue等。

  • concurrentmap新增了一些常见的符合操作

a) putIfAbset 若没有,则添加
b) 替换某个元素
c) 有条件删除某个元素等

ConcurrentHashMap

https://www.ibm.com/developerworks/cn/java/java-lo-concurrenthashmap/
这里的介绍还挺不错

  • 分段锁,使得写入并发量显著提高(针对Segment进行锁定)
  • 读数据不需要加锁!!
  • 迭代器不抛出ConcurrentModifiyException,弱一致性的迭代器
  • 因为分段锁对象数组没有暴露出来,所以客户端无法扩展concurrenthashmap的原子操作。

copyonwirtelist 、copyonwriteset

所有的更新操作都复制一份容器的副本进行修改(其中的元素需要被正确的发布,如果没有正确发布,读操作也不一定是线程安全的,可能会读到未构造完成的对象),复制的成本比较高,需要酌情衡量

BlockingQueue

几组对应的获取和添加元素方法

put和take方法会阻塞直到达到某个条件被唤醒(唤醒后仍可能会继续阻塞),offer和poll不会阻塞,但是支持设置定时!

  • 解耦生产者与消费者
  • 可以实现生产者与消费者模式,只要队列有界就能保证消费者消费不过来的时候阻塞生产者任务。

java中的几种阻塞队列实现:

  • ArrayListBlockingQueue

  • LinkedListBlockingQueue

  • PririotyBlockingQueue
    此队列是无界的。
    被put进去的元素必须自身实现Comparable接口(所以不允许插入null),定义优先级关系。
    <b>优先级队列并不是按照Comparable来将所有元素进行大小排序,他只保证最后一个将被take的元素一定是优先级最高的,这样可以避免全部元素排序的复杂度。</b>

  • SynchronousQueue
    源码分析较好的:http://blog.csdn.net/vickyway/article/details/50113429
    公平模式下使用FIFO队列,非公平模式使用LIFO栈。

当没有消费者正在take时,put方法将一直阻塞,当没有生产者执行put方法是,消费者take也将一直阻塞。
内部不存储元素.它非常适合于传递性设计,在这种设计中,在一个线程中运行的对象要将某些信息、事件或任务传递给在另一个线程中运行的对象

阻塞方法与中断方法

  • 阻塞

线程遇到以下情况时会暂停或阻塞
a) 等待内置锁(这种情况没有办法中断他,只有等到它拿到锁为止)
b) 等待Lock(可中断唤醒的)
c) Thread.sleep,不会放弃cpu时间,程序暂停。
d) 等待Thread.join另外一个线程的执行完成
e) 等待io操作结束

除了内置锁导致的阻塞都有办法去中断线程。后续的章节会提到

  • 中断

java中线程不能强制另外一个线程立刻停止,只能以发出interrupt信号的方式,另外的线程收到信号后自行判断是否应该结束。
调用方接收到InterruptException的时候,有几种处理方式:
a) 继续传递这个异常
b) 某些无法继续传递异常的场景下继续重新interrupt
c) 自我实现了中断策略的地方,可以屏蔽这个异常,具体参看关闭线程章节。

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

推荐阅读更多精彩内容

  • 一.线程安全性 线程安全是建立在对于对象状态访问操作进行管理,特别是对共享的与可变的状态的访问 解释下上面的话: ...
    黄大大吃不胖阅读 834评论 0 3
  • 5.1 同步容器类 同步容器类包括Vector和HashTable以及Collection.synchronize...
    大海孤了岛阅读 396评论 1 0
  • Java-Review-Note——4.多线程 标签: JavaStudy PS:本来是分开三篇的,后来想想还是整...
    coder_pig阅读 1,639评论 2 17
  • 一、设计线程安全的类 在设计线程安全类的过程中,需要包含以下三个基本要素: 找出构成对象状态的所有变量 找出约束状...
    端木轩阅读 580评论 1 3
  • 迤逦着,挣扎着,惬意着, 永远不知道另一个世界如何了 翻转,微鼾,静谧 看着无言的静谧 继而一阵喧哗 原来是天亮了
    LED阅读 106评论 0 0