java queue] 队列和 Deque 详细分析 -4. 疑惑，到底什么是阻塞队列？
区分阻塞队列和非阻塞队列的关键因素是什么？
按照大多数文章的介绍，阻塞队列支持阻塞特性，在队列满或为空时会阻塞，但是我想到队列必须是线程安全的，阻塞队列（前文表格中的那5个阻塞队列）都是利用悲观加锁，互斥做到线程安全的，貌似加锁在某种程度上也等价于阻塞，巧合的是非阻塞队列（比如ConcurrentLinkedQueue）又是利用乐观锁实现线程安全的，乐观锁可以理解成未加锁。
在《JAVA中的阻塞队列和非阻塞队列》一文中，介绍非阻塞队列时有如下：
基于锁的算法会带来一些活跃度失败的风险。如果线程在持有锁的时候因为阻塞I/O、页面错误、或其他原因发生延迟，很可能所有的线程都不能工作了。一个线程的失败或挂起不应该影响其他线程的失败或挂起，这样的算法称为
非阻塞算法；如果算法的每一个步骤中都有一些线程能够继续执行，那么这样的算法称为锁*（lock-free）算法。在线程间使用CAS进行协调，这样的算法如果能构建正确的话，它既是非阻塞的，又是锁*的。java中提供了基于CAS非阻塞算法实现的队列，比较有代表性的有ConcurrentLinkedQueue和LinkedTransferQueue，它们的性能一般比阻塞队列的好。
那么如果回答什么是阻塞队列，什么是非阻塞队列时，是不是2个要素都要提及？
4.1 答案
阻塞队列，是指多线程访问竞争资源时，当竞争资源已被某线程获取时，其它要获取该资源的线程需要阻塞等待！
虽然队列满了，会休眠，出队发现为空，就等待，也是阻塞，但不是阻塞队列的核心概念！
参见 《JUC回顾之-ArrayBlockingQueue底层实现和原理》
参考：
https://www.cnblogs.com/bjxq-cs88/p/9759571.html 什么是阻塞队列？
https://www.cnblogs.com/lemon-flm/p/7877898.html
https://baijiahao.baidu.com/s?id=1649350860832492296&wfr=spider&for=pc
推荐阅读
-
异步编程RxJava-介绍-前言 前段时间写了一篇对协程的一些理解，里面提到了不管是协程还是callback，本质上其实提供的是一种异步无阻塞的编程模式；并且介绍了java中对异步无阻赛这种编程模式的支持，主要提到了Future和CompletableFuture；之后有同学在下面留言提到了RxJava，刚好最近在看微服务设计这本书，里面提到了响应式扩展(Reactive extensions,Rx)，而RxJava是Rx在JVM上的实现，所有打算对RxJava进一步了解。 RxJava简介 RxJava的官网地址：https://github.com/ReactiveX/RxJava， 其中对RxJava进行了一句话描述：RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM. 大意就是：一个在Java VM上使用可观测的序列来组成异步的、基于事件的程序的库。 更详细的说明在Netflix技术博客的一篇文章中描述了RxJava的主要特点： 1.易于并发从而更好的利用服务器的能力。 2.易于有条件的异步执行。 3.一种更好的方式来避免回调地狱。 4.一种响应式方法。 与CompletableFuture对比 之前提到CompletableFuture真正的实现了异步的编程模式，一个比较常见的使用场景： CompletableFuture<Integer> future = CompletableFuture.supplyAsync(耗时函数); Future<Integer> f = future.whenComplete((v, e) -> { System.out.println(v); System.out.println(e); }); System.out.println("other..."); 下面用一个简单的例子来看一下RxJava是如何实现异步的编程模式： Observable<Long> observable = Observable.just(1, 2) .subscribeOn(Schedulers.io).map(new Func1<Integer, Long> { @Override public Long call(Integer t) { try { Thread.sleep(1000); //耗时的操作 } catch (InterruptedException e) { e.printStackTrace; } return (long) (t * 2); } }); observable.subscribe(new Subscriber<Long> { @Override public void onCompleted { System.out.println("onCompleted"); } @Override public void onError(Throwable e) { System.out.println("error" + e); } @Override public void onNext(Long result) { System.out.println("result = " + result); } }); System.out.println("other..."); Func1中以异步的方式执行了一个耗时的操作，Subscriber(观察者)被订阅到Observable(被观察者)中，当耗时操作执行完会回调Subscriber中的onNext方法。 其中的异步方式是在subscribeOn(Schedulers.io)中指定的，Schedulers.io可以理解为每次执行耗时操作都启动一个新的线程。 结构上其实和CompletableFuture很像，都是异步的执行一个耗时的操作，然后在有结果的时候主动告诉我结果。那我们还需要RxJava干嘛，不知道你有没有注意，上面的例子中其实提供2条数据流[1,2]，并且处理完任何一个都会主动告诉我，当然这只是它其中的一项功能，RxJava还有很多好用的功能，在下面的内容会进行介绍。 异步观察者模式 上面这段代码有没有发现特别像设计模式中的：观察者模式；首先提供一个被观察者Observable，然后把观察者Subscriber添加到了被观察者列表中； RxJava中一共提供了四种角色：Observable、Observer、Subscriber、Subjects Observables和Subjects是两个被观察者，Observers和Subscribers是观察者； 当然我们也可以查看一下源码，看一下jdk中的Observer和RxJava的Observer jdk中的Observer： public interface Observer { void update(Observable o, Object arg); } RxJava的Observer: public interface Observer<T> { void onCompleted; void onError(Throwable e); void onNext(T t); } 同时可以发现Subscriber是implements Observer的： public abstract class Subscriber<T> implements Observer<T>, Subscription 可以发现RxJava中在Observer中引入了2个新的方法：onCompleted和onError onCompleted：即通知观察者Observable没有更多的数据，事件队列完结 onError:在事件处理过程中出异常时，onError会被触发,同时队列自动终止，不允许再有事件发出。 正是因为RxJava提供了同步和异步两种方式进行事件的处理，个人觉得异步的方式更能体现RxJava的价值，所以这里给他命名为异步观察者模式。 好了，下面正式介绍RxJava的那些灵活的操作符，这里仅仅是简单的介绍和简单的实例，具体用在什么场景下，会在以后的文章中介绍 Maven引入
-
java queue] 队列和 Deque 详细分析 -4. 疑惑，到底什么是阻塞队列？