java 同步器SynchronousQueue详解及实例
同步器简介
学习以来对线程的操作有很大的改观，从c/c++的mutex到java的各种锁（当然不是嫌麻烦，java读写锁的实现还是带来不少好处的，但是sokcet的设计我就不敢恭维了，tcp和udp是两个类，弄得我现在对udp也不怎么熟悉）。其中最让我感到特别刚需的设计就是同步器，除了countdownlatch,剩下的都比较刚需，cyclicbarrier我现在唯一能感觉他的好用处就是循环打印a,b，exchanger和SynchronousQueue我一直没发现什么作用，两个就适合生产者消费者问题。以上就是四大同步器，听说过2个以上的就很厉害了，有些场合太难想了。
场景思路
这次说最后两个用的场景吧，我要做的事情呢，是采集一堆数据，然后采集另外的数据综合处理，但是两个数据是和时间相关的，如果顺序执行的话，那么处理结果的可信度越低，最初的设想就是利用异步处理，两个数据采集同时进行，然后一起处理，futuretask，就作为首选，我的采集信息还是周期性的任务，必需要用定时的线程池了，但是这种线程池（别说timer，这个类更建议用线程池替换）并没有为异步处理做返回值，我也没办法直接获取处理的数据了，无奈的情况下只能用线程来做了，同时也必须要用同步器来同步了，用手动阻塞线程然后唤醒这个行为实在是太不可取了，你全唤醒了，可能造成不该运行的代码开始运行，唤醒单个，还得看cpu的调度，于是想到了exchanger和SynchronousQueue，我最终选取了SynchronousQueue。
SynchronousQueue
其实就是特殊的阻塞队列，特殊就特殊在他最多放一个元素，而且这个元素不在特定的时间消费掉就没了，而且永远长度都是0，具体看api就发现能用的方法没几个，3个是放入，2个是取走。
demo
生产者，消息最多存放1分钟
public void run() {
try {
queue.offer(i++,1,TimeUnit.MINUTES);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("add");
}
消费者
System.out.println(queue.poll(1,TimeUnit.SECONDS));
用了这个同步器，这种定时生产者消费者问题，代码量就很少，不需要自己再写同步的代码了。也避免了最初唤醒阻塞带来的不可预估性。
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
-
本文向大家介绍Java 同步锁(synchronized)详解及实例，包括了Java 同步锁(synchronized)详解及实例的使用技巧和注意事项，需要的朋友参考一下 Java 同步锁(synchronized)详解及实例 Java中cpu分给每个线程的时间片是随机的并且在Java中好多都是多个线程共用一个资源，比如火车卖票，火车票是一定的，但卖火车票的窗口到处都有，每个窗口就相当于一个线程，
-
本文向大家介绍详解Java线程同步器CountDownLatch，包括了详解Java线程同步器CountDownLatch的使用技巧和注意事项，需要的朋友参考一下 Java程序有的时候在主线程中会创建多个线程去执行任务，然后在主线程执行完毕之前，把所有线程的任务进行汇总，以前可以用线程的join方法，但是这个方法不够灵活，我们可以使用CountDownLatch类，实现更优雅,而且使用线程池的
-
本文向大家介绍Java中CountDownLatch进行多线程同步详解及实例代码，包括了Java中CountDownLatch进行多线程同步详解及实例代码的使用技巧和注意事项，需要的朋友参考一下 Java中CountDownLatch进行多线程同步详解 CountDownLatch介绍 在前面的Java学习笔记中，总结了Java中进行多线程同步的几个方法： 1、synchronized关键字进行同
-
本文向大家介绍Java 线程同步详解，包括了Java 线程同步详解的使用技巧和注意事项，需要的朋友参考一下 Java 线程同步根本上是要符合一个逻辑:加锁------>修改------>释放锁 1、同步代码块 示例如下： 示例中希望按照顺序依次输出整数。 通常同步代码块是需要锁定的对象，一般是需要并发访问的共享资源，任何线程在修改指定资源之前都首先对该资源加锁，在加锁期间其它线程无法修改该资源。从
-
本文向大家介绍java 线程同步详细介绍及实例代码，包括了java 线程同步详细介绍及实例代码的使用技巧和注意事项，需要的朋友参考一下 java 线程同步 概要： 为了加快代码的运行速度，我们采用了多线程的方法。并行的执行确实让代码变得更加高效，但随之而来的问题是，有很多个线程在程序中同时运行，如果它们同时的去修改一个对象，很可能会造成讹误的情况，这个时候我们需要用一种同步的机制来管理这些线程。
-
主要内容：1 SynchronousQueue的概述,2 SynchronousQueue的原理,2.1 主要属性,2.2 主要内部类,2.3 构造器,2.4 非公平模式原理,2.5 公平模式原理,2.6 入队操作,2.7 出队操作,2.8 无意义操作,3 SynchronousQueue的总结基于JDK1.8详细介绍了SynchronousQueue的底层源码实现，包括“没有容量”的原理，以及“入队列“、“出队列”等操作源码。 1 SynchronousQueue的概述 public clas