ConcurrentLinkedQueue使用实例

Raaabbit 发布于2019-08-16 10:45 / 1947人阅读

摘要：序是一个基于链接节点的无界线程安全队列，它采用先进先出的规则对节点进行排序，当我们添加一个元素的时候，它会添加到队列的尾部，当我们获取一个元素时，它会返回队列头部的元素。的模型，默认的是用这个来实现的。

序

ConcurrentLinkedQueue是一个基于链接节点的无界线程安全队列，它采用先进先出的规则对节点进行排序，当我们添加一个元素的时候，它会添加到队列的尾部，当我们获取一个元素时，它会返回队列头部的元素。

对比

queue	阻塞与否	是否有界	线程安全保障	适用场景	注意事项
ArrayBlockingQueue	阻塞	有界	一把全局锁	生产消费模型，平衡两边处理速度	--
LinkedBlockingQueue	阻塞	可配置	存取采用2把锁	生产消费模型，平衡两边处理速度	无界的时候注意内存溢出问题
ConcurrentLinkedQueue	非阻塞	无界	CAS	对全局的集合进行操作的场景	size() 是要遍历一遍集合，慎用

实例

由于ConcurrentLinkedQueue是无界的，所以使用的时候要特别注意内存溢出问题。akka的actor模型，默认的mailbox是用这个来实现的。

object UnboundedMailbox {
  class MessageQueue extends ConcurrentLinkedQueue[Envelope] with UnboundedQueueBasedMessageQueue {
    final def queue: Queue[Envelope] = this
  }
}

MyUnboundedMailbox

public class MyUnboundedMailbox implements MailboxType,
  ProducesMessageQueue {

  // This is the MessageQueue implementation
  public static class MyMessageQueue implements MessageQueue,
      MyUnboundedMessageQueueSemantics {
    private final Queue queue =
      new ConcurrentLinkedQueue();

    // these must be implemented; queue used as example
    public void enqueue(ActorRef receiver, Envelope handle) {
      queue.offer(handle);
    }
    public Envelope dequeue() { return queue.poll(); }
    public int numberOfMessages() { return queue.size(); }
    public boolean hasMessages() { return !queue.isEmpty(); }
    public void cleanUp(ActorRef owner, MessageQueue deadLetters) {
      for (Envelope handle: queue) {
        deadLetters.enqueue(owner, handle);
      }
    }
  }

  // This constructor signature must exist, it will be called by Akka
  public MyUnboundedMailbox(ActorSystem.Settings settings, Config config) {
    // put your initialization code here
  }

  // The create method is called to create the MessageQueue
  public MessageQueue create(Option owner, Option system) {
    return new MyMessageQueue();
  }
}

doc

Actors and Green Threads in Java Demystified

Mailboxes

Mailbox.scala

海外云主机服务器托管 hadoop使用实例使用自定义镜像创建实例 h5中webrtc使用实例没有实例可以使用云服务器么

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/70387.html

ConcurrentLinkedQueue使用实例

摘要：序是一个基于链接节点的无界线程安全队列，它采用先进先出的规则对节点进行排序，当我们添加一个元素的时候，它会添加到队列的尾部，当我们获取一个元素时，它会返回队列头部的元素。的模型，默认的是用这个来实现的。序 ConcurrentLinkedQueue是一个基于链接节点的无界线程安全队列，它采用先进先出的规则对节点进行排序，当我们添加一个元素的时候，它会添加到队列的尾部，当我们获取一个元...

Java3y 2019-08-19 10:40 评论0 收藏0
Java多线程进阶（二九）—— J.U.C之collections框架：ConcurrentLink

摘要：所以，在并发量适中的情况下，一般具有较好的性能。字段指向队列头，指向队列尾，通过来操作字段值以及对象的字段值。单线程的情况下，元素入队比较好理解，直接线性地在队首插入元素即可。 showImg(https://segmentfault.com/img/bVbguGd?w=1200&h=800); 本文首发于一世流云专栏：https://segmentfault.com/blog... ...

Cobub 2019-08-19 11:05 评论0 收藏0
非阻塞同步算法实战（一）：ConcurrentLinkedQueue

摘要：注意这里指的不是当次而是之后，所以如果我们使用队列的方法返回，就知道队列是否为空，但是不知道之后是否为空，并且，当关注的操作发生时，在插入或取出操作的返回值里告知此信息，来指导是否继续注册写操作。前言本文写给对ConcurrentLinkedQueue的实现和非阻塞同步算法的实现原理有一定了解，但缺少实践经验的朋友，文中包括了实战中的尝试、所走的弯路，经验和教训。背景介绍 ...

EscapedDog 2019-08-14 11:38 评论0 收藏0
通俗易懂，JDK 并发容器总结

摘要：线程安全的线程安全的，在读多写少的场合性能非常好，远远好于高效的并发队列，使用链表实现。这样带来的好处是在高并发的情况下，你会需要一个全局锁来保证整个平衡树的线程安全。该文已加入开源项目：JavaGuide（一份涵盖大部分Java程序员所需要掌握的核心知识的文档类项目，Star 数接近 14 k）。地址:https://github.com/Snailclimb... 一 JDK ...

curlyCheng 2019-08-16 13:58 评论0 收藏0
【实战Java高并发程序设计】连载1–Java中的指针：Unsafe类

摘要：不难看出，方法的内部，必然是使用原子指令来完成的。它是一个内部使用的专属类。注意根据类加载器的工作原理，应用程序的类由加载。加载器没有对象的对象，因此试图获得这个类加载器会返回。如果你对技术有着不折不挠的追求，应该还会特别在意incrementAndGet() 方法中compareAndSet()的实现。现在，就让我们更进一步看一下它把！public final boolean co...

EasonTyler 2019-08-14 15:12 评论0 收藏0