面试侃集合|SynchronousQueue非公平模式篇

面试官：好了，你也休息了十分钟了，咱们接着往下聊聊SynchronousQueue的非公平模式吧。

岚县网站制作公司哪家好，找创新互联建站！从网页设计、网站建设、微信开发、APP开发、自适应网站建设等网站项目制作，到程序开发，运营维护。创新互联建站从2013年创立到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选创新互联建站。

Hydra：好的，有了前面公平模式的基础，非公平模式理解起来就非常简单了。公平模式下，SynchronousQueue底层使用的是TransferQueue，是一个先进先出的队列，而非公平模式与它不同，底层采用了后进先出的TransferStack栈来实现。

下面我们还是先写一个例子来看看效果，首先创建3个线程使用put方法向SynchronousQueue中插入数据，结束后再使用3个线程调用take方法：

 
 
 
 
  
  
  
  SynchronousQueue queue=new SynchronousQueue<>(false);
  
  
  
  
  
  
  
  @AllArgsConstructor
  
  
  
  class PutThread implements Runnable{
  
  
  
      int i;
  
  
  
      @SneakyThrows
  
  
  
      @Override
  
  
  
      public void run() {
  
  
  
          queue.put(i);
  
  
  
          System.out.println("putThread "+i+" end");
  
  
  
      }
  
  
  
  }
  
  
  
  class TakeThread implements Runnable{
  
  
  
      @SneakyThrows
  
  
  
      @Override
  
  
  
      public void run() {
  
  
  
          System.out.println("takeThread take: "+queue.take());
  
  
  
      }
  
  
  
  }
  
  
  
  
  
  
  
  for (int i = 1; i <=3; i++) {
  
  
  
      new Thread(new PutThread(i)).start();
  
  
  
      Thread.sleep(1000);
  
  
  
  }
  
  
  
  for (int i = 1; i <=3 ; i++) {
  
  
  
      new Thread(new TakeThread()).start();
  
  
  
      Thread.sleep(1000);
  
  
  
  }

运行上面的代码，查看结果：

 
 
 
 
  
  
  
  takeThread take: 3
  
  
  
  putThread 3 end
  
  
  
  takeThread take: 2
  
  
  
  putThread 2 end
  
  
  
  takeThread take: 1
  
  
  
  putThread 1 end

可以看到，生产者线程在执行完put后会进行阻塞，直到有消费者线程调用take方法取走了数据，才会唤醒被阻塞的线程。并且，数据的出队与入队顺序是相反的，即非公平模式下采用的是后进先出的顺序。

原图

面试官：就是把结构从队列换成了栈，真就这么简单?

Hydra：并不是，包括底层节点以及出入栈的逻辑都做了相应的改变。我们先看节点，在之前的公平模式中队列的节点是QNode，非公平模式下栈中节点是SNode，定义如下：

 
 
 
 
  
  
  
  volatile SNode next; // 指向下一个节点的指针
  
  
  
  volatile SNode match; // 存放和它进行匹配的节点
  
  
  
  volatile Thread waiter;  // 保存阻塞的线程
  
  
  
  Object item;                
  
  
  
  int mode;
  
  
  
  SNode(Object item) {
  
  
  
      this.item = item;
  
  
  
  }

和QNode类似，如果是生产者构建的节点，那么item非空，如果是消费者产生的节点，那么item为null。此外还有一个mode属性用来表示节点的状态，它使用TransferStack中定义的3个常量来表示不同状态：

 
 
 
 
  
  
  
  static final int REQUEST    = 0; //消费者
  
  
  
  static final int DATA       = 1; //生产者
  
  
  
  static final int FULFILLING = 2; //匹配中状态

TransferStack中没有携带参数的构造函数，使用一个head节点来标记栈顶节点：

 
 
 
 
  
  
  
  volatile SNode head;

面试官：基本结构就讲到这吧，还是老规矩，先从入队操作开始分析吧。

Hydra：当栈为空、或栈顶元素的类型与自己相同时，会先创建一个SNode节点，并将它的next节点指向当前栈顶的head，然后将head指针指向自己。这个过程中通过使用CAS保证线程安全，如果失败则退出，在循环中采取自旋的方式不断进行尝试，直到节点入栈成功。用一张图来表示两个线程同时入栈的场景：

原图

当节点完成入栈后，调用awaitFulfill方法，等待匹配的操作的到来。在这一过程中，会使节点对应的线程进行自旋或挂起操作，直到匹配操作的节点将自己唤醒，或被其他线程中断、等待超时。

当入栈后的节点是栈顶节点，或者节点的类型为FULFILLING匹配状态时，那么可能会马上完成匹配，因此先进行自旋，当超过自旋次数上限后再挂起。而如果节点在自旋过程中，有新的节点压入栈顶，会将非栈顶节点剩余的自旋次数直接清零，挂起线程避免浪费资源。

原图

面试官：你上面也说了，挂起的线程有可能会超时或者被中断，这时候应该怎么处理?

Hydra：当这两种情况出现时，SNode会将match属性设为自身，退出awaitFulfill方法，然后调用clean方法将对应的节点清理出栈。具体情形可分为两种情况。先说简单的情况，如果清理的是栈顶节点，那么直接将head节点指向它的next节点，即将当前栈顶节点弹出即可。

面试官：那么如果要删除的节点不是栈顶的节点呢?

Hydra：如果清理的不是栈顶节点，会稍微有一些麻烦。因为栈的底层是一个单向的链表结构，所以需要从栈顶head节点开始遍历，遍历到被删除节点的后继节点为止。所以在清除工作开始前，先使用了一个past节点标记需要删除节点的下一个节点，作为结束遍历的标记。

然后创建一个标记节点p，初始时指向head节点，开始循环，如果p的next节点不是需要被删除的节点，那么就将p向后移一个位置，直到找到这个需要被删除的中断或超时的节点，然后将p的next指向这个删除节点的next节点，在逻辑上完成链表中节点的删除。

原图

面试官：单一类型节点的入栈应该说完了吧，接下来说说不同类型节点间是如何实现的匹配操作吧?

Hydra：好的，那我们先回顾一点上面的知识，前面说过每个节点有一个mode属性代表它的模式，REQUEST表示它是消费者，DATA表示是生产者，FULFILLING表明正处于匹配中的状态。

在一个新的线程调用方法时，先判断它的类型mode是什么，如果和当前栈顶head节点类型不同，且head节点的状态不为匹配中时，将它的状态设置为FULFILLING|mode，压入栈中。然后将尝试匹配新的head节点和它的next节点，如果匹配成功，会将next节点的match属性设置为head节点，唤醒挂起的next节点中的线程。

在完成匹配后，当前头节点对应的线程会协助推进head节点，将head指向next节点的下一个节点，即完成了栈顶两节点的出栈。最终消费者线程会返回匹配的生产者节点中的item数据值，而生产者线程也会结束运行退出。

我们以栈中当前节点为DATA类型，新节点为REQUEST类型画一张图，来直观的感受一下上面的流程：

原图

面试官：总算是讲完了，能对SynchronousQueue做一个简单的总结吗?

Hydra：SynchronousQueue基于底层结构，实现了线程配对通信这一机制。在它的公平模式下使用的是先进先出(FIFO)的队列，非公平模式下使用的是后进先出(LIFO)的栈，并且SynchronousQueue没有使用synchronized或ReentrantLock，而是使用了大量的CAS操作来保证并发操作。可能我们在平常的工作中使用场景不是很多，但是在线程池的设计中使用了SynchronousQueue，还是有很重要的应用场景的。

面试官：讲的还行，不过刚才这些和公平模式听起来感觉区别不大啊，没有什么技术含量。这样吧，你明天过来我们加试一场，我再给你打分。

Hydra：(溜了溜了，还是找家别的靠谱公司吧……)

文章标题：面试侃集合|SynchronousQueue非公平模式篇
分享地址：http://www.shufengxianlan.com/qtweb/news33/238283.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容