SynchronousQueue

今天药忘吃喽~ 2022-04-17 01:36 216阅读 0赞

**分享一下我老师大神的人工智能教程！零基础，通俗易懂！[http://blog.csdn.net/jiangjunshow][http_blog.csdn.net_jiangjunshow]**

**也欢迎大家转载本篇文章。分享知识，造福人民，实现我们中华民族伟大复兴！**

SynchronousQueue是这样 一种阻塞队列，其中每个 put 必须等待一个 take，反之亦然。同步队列没有任何内部容量，甚至连一个队列的容量都没有。  
 不能在同步队列上进行 peek，因为仅在试图要取得元素时，该元素才存在；  
 除非另一个线程试图移除某个元素，否则也不能（使用任何方法）添加元素；  
 也不能迭代队列，因为其中没有元素可用于迭代。队列的头是尝试添加到队列中的首个已排队线程元素； 如果没有已排队线程，则不添加元素并且头为 null。  
 对于其他 Collection 方法（例如 contains），SynchronousQueue 作为一个空集合。此队列不允许 null 元素。  
 同步队列类似于 CSP 和 Ada 中使用的 rendezvous 信道。  
 它非常适合于传递性设计，在这种设计中，在一个线程中运行的对象要将某些信息、  
 事件或任务传递给在另一个线程中运行的对象，它就必须与该对象同步。  
 对于正在等待的生产者和使用者线程而言，此类支持可选的公平排序策略。默认情况下不保证这种排序。  
 但是，使用公平设置为 true 所构造的队列可保证线程以 FIFO 的顺序进行访问。 公平通常会降低吞吐量，但是可以减小可变性并避免得不到服务。

构造函数

<table> 
 <tbody> 
  <tr> 
   <th colspan="12">Public Constructors</th> 
  </tr> 
  <tr> 
   <td></td> 
   <td><a href="http://developer.android.com/reference/java/util/concurrent/SynchronousQueue.html#SynchronousQueue%28%29" rel="nofollow">SynchronousQueue</a>() 
    <div>
      Creates a&nbsp; SynchronousQueue&nbsp;with nonfair access policy. 
    </div></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><a href="http://developer.android.com/reference/java/util/concurrent/SynchronousQueue.html#SynchronousQueue%28boolean%29" rel="nofollow">SynchronousQueue</a>(boolean&nbsp;fair) 
    <div>
      Creates a&nbsp; SynchronousQueue&nbsp;with the specified fairness policy. 
    </div></td> 
  </tr> 
 </tbody> 
</table>

注意1：它一种阻塞队列，其中每个 put 必须等待一个 take，反之亦然。  
   同步队列没有任何内部容量，甚至连一个队列的容量都没有。  
  注意2：它是线程安全的，是阻塞的。  
  注意3:不允许使用 null 元素。  
  注意4：公平排序策略是指调用put的线程之间，或take的线程之间。  
 公平排序策略可以查考ArrayBlockingQueue中的公平策略。  
  注意5:SynchronousQueue的以下方法很有趣：  
    \* iterator() 永远返回空，因为里面没东西。  
    \* peek() 永远返回null。  
    \* put() 往queue放进去一个element以后就一直wait直到有其他thread进来把这个element取走。  
    \* offer() 往queue里放一个element后立即返回，如果碰巧这个element被另一个thread取走了，offer方法返回true，认为offer成功；否则返回false。  
    \* offer(2000, TimeUnit.SECONDS) 往queue里放一个element但是等待指定的时间后才返回，返回的逻辑和offer()方法一样。  
    \* take() 取出并且remove掉queue里的element（认为是在queue里的。。。），取不到东西他会一直等。  
    \* poll() 取出并且remove掉queue里的element（认为是在queue里的。。。），只有到碰巧另外一个线程正在往queue里offer数据或者put数据的时候，该方法才会取到东西。否则立即返回null。  
    \* poll(2000, TimeUnit.SECONDS) 等待指定的时间然后取出并且remove掉queue里的element,其实就是再等其他的thread来往里塞。  
    \* isEmpty()永远是true。  
    \* remainingCapacity() 永远是0。  
    \* remove()和removeAll() 永远是false。  
实例1  
import java.util.Random;  
import java.util.concurrent.SynchronousQueue;  
import java.util.concurrent.TimeUnit;  
public class   Test  \{  
 /\*\*  
  \* @param args  
  \*/  
  public static void   main (String\[\] args) \{  
  SynchronousQueue<String> queue=new SynchronousQueue();  
  // TODO Auto-generated method stub  
   for (int i=0;i<10;i++)  
   new Thread(new ThreadProducer(queue)).start();  
   for (int i=0;i<10;i++)  
   new Thread(new ThreadConsumer(queue)).start();  
 \}  
\}  
class   ThreadProducer  implements Runnable  
\{  
 ThreadProducer(SynchronousQueue<String> queue)  
 \{  
  this.queue=queue;  
 \}  
 SynchronousQueue<String> queue;  
 static int cnt=0;  
 public void run()  
 \{  
  String name="";  
  int val=0;  
  Random random =new Random(System.currentTimeMillis());  
   while (true)  
  \{  
   cnt=(cnt+1)&0xFFFFFFFF;  
     
    try \{  
    val=random.nextInt()%15;  
     if (val<5)  
    \{  
     name="offer name:"+cnt;  
     queue.offer(name);  
    \}  
     else if (val<10)  
    \{  
     name="put name:"+cnt;  
     queue.put(name);  
    \}  
     else  
    \{  
     name="offer wait time and name:"+cnt;  
     queue.offer(name, 1000,TimeUnit.MILLISECONDS);  
    \}  
   Thread.sleep(1);  
   \} catch (InterruptedException e)  
   \{  
    e.printStackTrace();  
   \}  
  \}  
 \}  
\}  
class  ThreadConsumer  implements  Runnable  
\{  
 ThreadConsumer(SynchronousQueue<String> queue)  
 \{  
  this.queue=queue;  
 \}  
 SynchronousQueue<String> queue;  
  public void  run()  
 \{  
  String name;  
   while (true)  
  \{  
   try\{  
    name=queue.take();  
    System.out.println("take "+name);  
   Thread.sleep(1);  
   \}catch(InterruptedException e)  
   \{  
    e.printStackTrace();  
   \}  
  \}  
 \}  
\}

SynchronousQueue是BlockingQueue的一种实现。关于BlockingQueue的更多内容请参考《 **[BlockingQueue][]** 》

#### 给我老师的人工智能教程打call！[http://blog.csdn.net/jiangjunshow][http_blog.csdn.net_jiangjunshow] ####

![这里写图片描述][SouthEast]

[http_blog.csdn.net_jiangjunshow]: https://blog.csdn.net/jiangjunshow/article/details/77338485
[BlockingQueue]: http://hubingforever.blog.163.com/blog/static/17104057920107415915820/
[SouthEast]: /images/20220417/0be997d8c06f465d92fe4090655073a4.png