? | Disruptor | ArrayBlockingQueue | LinkedBlockingQueue |
实现原理 |
固定大小的环形的ringbuffer存放元素 ? |
固定大小的数组存放元素,通过插入、取出两个下标协同循环使用数组 | 用链表存放元素,大小不固定 |
锁 | 无锁,多生产者之间有sequence竞争,采用比锁轻量的CAS操作 | 有锁,且读和写是同一个锁,锁粒度最大 | 有锁,读锁和写锁分开 |
gc | 元素重用,gc较少 | 元素重用,gc较少 | 元素不重用,gc较多 |
其他 | 考虑cpu cacheline,避免false sharing,多种等待策略,可根据具体情况选用。比如自旋、wait、自旋一定时间然后wait等。 | 等待时线程wait,条件满足时,notify,线程切换较多 | 等待时线程wait,条件满足时,notify,线程切换较多 |
适用场景 |
1、性能最好 2、消费者其实是一种广播的方式,即每个元素,每个消费者都要消费 |
1、多并发时性能不好。 2、典型消费者-生产者模式,一个元素只给一个消费者消费 |
1、并发性比ArrayBlockingQueue好,但gc较多。 2、典型消费者-生产者模式,一个元素只给一个消费者消费 |