Java 并发数据结构

原创
2015/06/15 08:19
阅读数 311

[TOCM]

因为Java提供了一些非线程安全的数据结构如HashMap,ArrayList,HashSet等。所有在多线程环境中需要使用支持并发访问操作的数据结构。

并发List

Vector,CopyOnWriteArrayList 是线程安全的List。ArrayList是线程不安全的。如果一定要使用,需要: Collections.synchronizedList(List list) 进行包装。 CopyOnWriteArrayList的内部实现与Vector是不同的,Copy-On-Write就是CopyOnWriteArrayList的内部实现机制。在进行写操作的时候就会复制该对象来操作,读操作直接返回。操作过程中不进行同步。 Vector使用了同步的关键词,所有的get()都必须取得对象锁才能进行。在高并发的时候会有推累系统性能

一般认为读多写少使用CopyOnWriteArrayList。写多读少使用Vector。

并发Set

与List相似,并发的Set也有一个CopyOnWriteSet。内部实现完全依赖CopyOnWriteList。并发写多的情况可以通过 Collections.synchronizedSet(Set set)

并发Map

与List,Set相似也提供了一个 Collections.synchronizedMap(Map map) 创建一个线程安装的Map,但是这个Map并不是性能最佳的。JDK提供一个高并发的Map ConcurrentHashMap。相比通过Collections创建的Map,ConcurrentHashMap 不会锁住整个对象,而是使用锁分离(分块),推荐使用ConcurrentHashMap。

并发Queue

  • ConcurrentLikedQueue
  • BlockingQueue
    • offer(object) 将object放入BlockingQueue里,如果BlockingQueue有充足的空间返回 true,反之 false(该方法不阻塞当前执行的执行方法的线程)
    • offer(E e,long timeout,TimeUnit unit) 可以等待设置的时间。如果在指定的时间都没有添加到Queue就放回失败
    • put(object) 把object放到Queue中。如果空间不够就阻塞调用方法的线程直到有空闲空间才继续
    • pull(time) 取出Queue首位的对象,可以等待指定的时间。超时返回null
    • pull(long timeout,TimeUnit unit) 取出Queue首位的对象,可以等待指定的时间。超时认为失败
    • take() 取走首位对象,若Queue为空,会等到有等数据到来后不在进行堵塞

并发Deque(Double-Ended-Quene)

相比Quene,具有 addFirst(E) addList(E) 等方法,实现相对复杂,实际工作中并没有遇到过就不做介绍了。

展开阅读全文
加载中
点击引领话题📣 发布并加入讨论🔥
0 评论
0 收藏
0
分享
返回顶部
顶部