Multi-Th:同步容器

作者: 甚了 | 来源:发表于2016-12-04 10:31 被阅读12次

    ConcuttentHashMap

    同步容器类在执行每个操作期间都持有一个锁。与HashMap一样,ConcurrentHashMap也是一个基于散列的Map,但是使用了一种完全不同的加锁策略来提供更高的并发性和伸缩性。

    ConcurrentHashMap并不是将每个方法都在同一个锁上tong bu同步并使得每次只能有一个线程访问容器。而是使用一种粒度更细的加锁机制来实现更大程度的共享,这种机制是“分段锁”。在这种机制中,任意数量的读取线程可以并发的访问Map,执行读取操作的线程和执行写入的线程可以并发的访问Map,并且一定数量的写入线程可以并发的修改Map。

    ConcurrentHashMap与其他同步容器:提供的迭代器不会抛出ConcurrentModificationException,因此不需要为迭代过程加锁。

    尽管有很多的改进,但是对于整个Map进行计算的操作(例如:size()、isEmpty())会被削弱。由于size()返回的结果在计算时可能已经过期,它返回饿实际上是一个估计值。

    在ConcurrentHashMap的实现中使用了一个包含16个锁的数组,每个锁保护所有散列桶的1/16,其中第N个散列桶由第(N mod 16)个锁来保护。如果散列函数具有合理的分布性,并且关键字能都实现均匀分布,那么这差不多能够把对锁的请求减少到原来的1/16

    CopyOnWriteArrayList

    CopyOnWriteArraySet

    CopyOnWriteMap

    “写入时复制”容器的线程安全性在于,只要正确的发布一个事实不可变的对象,那么在访问该对象时就不再需要进一步的同步。在每次修改时,都会创建并重新发布一个新的容器副本,从而实现可变性。

    BlockingQueue

    put和take方法回阻塞,offer和poll支持定时。

    • put 方法在队列已满时,将阻塞直到有空间可用;
    • take 方法在队列为空时,将阻塞直到有元素可用;

    阻塞队列支持 “生产者-消费者”模式。(Executor任务框架中体现了这种模式)

    BlockingQueue有多种实现,LinkedBlockingQueue、ArrayBlocking、PriorityBlockingQueue、SynchronousQueue

    SynchronousQueue : 并不是真正的队列,实际上它维护的是一组线程,而不是存储空间,这些线程等待着把元素加入或者移出队列。这种实现方式,可以直接交付工作,从而降低了将数据从生产者移动到消费者的延迟。

    BlockingDeque

    双端队列,应用于“工作密取”模式,与“生产者-消费者”模式不同,在该模式中,每个消费者都有各自的的双端队列。如果一个消费者完成了自己双端队列的工作,那么它可以从其他消费者双端队列末尾秘密的获取工作,这样消费者间并不会发生竞争。

    双端队列具体实现 ArrayDeque、LinkedBlockingDeque

    相关文章

      网友评论

        本文标题:Multi-Th:同步容器

        本文链接:https://www.haomeiwen.com/subject/hpkhmttx.html