最新公告
  • 欢迎您光临立业阁,本站秉承服务宗旨 履行“站长”责任,销售只是起点 服务永无止境!立即加入我们
  • java多线程和并发面试题目(第4题,附答案)_Java教程


    4、ConcurrentLinkedQueue非阻塞无界链表队列

    ConcurrentLinkedQueue是一个线程安全的队列,基于链表结构实现,是一个无界队列,理论上来说队列的长度可以无限扩大。

    与其他队列相同,ConcurrentLinkedQueue也采用的是先进先出(FIFO)入队规则,对元素进行排序。 (推荐学习:java面试题目

    当我们向队列中添加元素时,新插入的元素会插入到队列的尾部;而当我们获取一个元素时,它会从队列的头部中取出。

    因为ConcurrentLinkedQueue是链表结构,所以当入队时,插入的元素依次向后延伸,形成链表;而出队时,则从链表的第一个元素开始获取,依次递增;

    值得注意的是,在使用ConcurrentLinkedQueue时,如果涉及到队列是否为空的判断,切记不可使用size()==0的做法,因为在size()方法中,是通过遍历整个链表来实现的,在队列元素很多的时候,size()方法十分消耗性能和时间,只是单纯的判断队列为空使用isEmpty()即可。

    public class ConcurrentLinkedQueueTest {
    public static int threadCount = 10;
    public static ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<String>();
    static class Offer implements Runnable {
    public void run() {
    //不建议使用 queue.size()==0,影响效率。可以使用!queue.isEmpty()
    if (queue.size() == 0) {
    String ele = new Random().nextInt(Integer.MAX_VALUE) + "";
    queue.offer(ele);
    System.out.println("入队元素为" + ele);
    }
    }
    }
    static class Poll implements Runnable {
    public void run() {
    if (!queue.isEmpty()) {
    String ele = queue.poll();
    System.out.println("出队元素为" + ele);
    }
    }
    }
    public static void main(String[] agrs) {
    ExecutorService executorService = Executors.newFixedThreadPool(4);
    for (int x = 0; x < threadCount; x++) {
    executorService.submit(new Offer());
    executorService.submit(new Poll());
    }
    executorService.shutdown();
    }
    }

    一种输出:

    入队元素为313732926
    出队元素为313732926
    入队元素为812655435
    出队元素为812655435
    入队元素为1893079357
    出队元素为1893079357
    入队元素为1137820958
    出队元素为1137820958
    入队元素为1965962048
    出队元素为1965962048
    出队元素为685567162
    入队元素为685567162
    出队元素为1441081163
    入队元素为1441081163
    出队元素为1627184732
    入队元素为1627184732

    ConcurrentLinkedQuere类图

    java-63.png

    如图ConcurrentLinkedQueue中有两个volatile类型的Node节点分别用来存在列表的首尾节点,其中head节点存放链表第一个item为null的节点,tail则并不是总指向最后一个节点。

    Node节点内部则维护一个变量item用来存放节点的值,next用来存放下一个节点,从而链接为一个单向无界列表。

    public ConcurrentLinkedQueue(){
    head=tail=new Node<E>(null);
    }

    如上代码初始化时候会构建一个 item 为 NULL 的空节点作为链表的首尾节点。

    Offer 操作offer 操作是在链表末尾添加一个元素,

    下面看看实现原理。

    public boolean offer(E e) {
    //e 为 null 则抛出空指针异常
    checkNotNull(e);
    //构造 Node 节点构造函数内部调用 unsafe.putObject,后面统一讲
    final Node<E> newNode = new Node<E>(e);
    //从尾节点插入
    for (Node<E> t = tail, p = t; ; ) {
    Node<E> q = p.next;
    //如果 q=null 说明 p 是尾节点则插入
    if (q == null) {
    //cas 插入(1)
    if (p.casNext(null, newNode)) {
    //cas 成功说明新增节点已经被放入链表,然后设置当前尾节点(包含 head,1,3,5.。。个节点为尾节点)
    if (p != t)// hop two nodes at a time
    casTail(t, newNode); // Failure is OK. return true;
    }
    // Lost CAS race to another thread; re-read next
    } else if (p == q)//(2)
    //多线程操作时候,由于 poll 时候会把老的 head 变为自引用,然后 head 的 next 变为新 head,所以这里需要
    //重新找新的 head,因为新的 head 后面的节点才是激活的节点
    p = (t != (t = tail)) ? t : head;
    else
    // 寻找尾节点(3)
    p = (p != t && t != (t = tail)) ? t : q;
    }
    }

    从构造函数知道一开始有个item为null的哨兵节点,并且head和tail都是指向这个节点。

    以上就是java多线程和并发面试题目(第4题,附答案)的详细内容,更多请关注liyege.cn其它相关文章!

    常见问题FAQ

    免费下载或者VIP会员专享资源能否直接商用?
    本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用者承担。更多说明请参考 VIP介绍。
    提示下载完但解压或打开不了?
    最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度网盘软件或迅雷下载。若排除这种情况,可在对应资源底部留言,或 联络我们.。
    找不到素材资源介绍文章里的示例图片?
    对于PPT,KEY,Mockups,APP,网页模版等类型的素材,文章内用于介绍的图片通常并不包含在对应可供下载素材包内。这些相关商业图片需另外购买,且本站不负责(也没有办法)找到出处。 同样地一些字体文件也是这种情况,但部分素材会在素材包内有一份字体下载链接清单。
    • 1168会员总数(位)
    • 111858资源总数(个)
    • 2本周发布(个)
    • 0 今日发布(个)
    • 244稳定运行(天)

    提供最优质的资源集合

    立即查看 了解详情
    冀ICP备19022365号-1 百度地图

    侵权联系邮箱[email protected]

    立业阁(www.liyege.cn)免费提供wordpress主题模板、dedecms模板、帝国cms模板、小说网站源码、电影网站源码以及网络技术分享,建站源码,小说模板,电影模板,网赚教程,VPS推荐