相应式编程之手写Reactor

媒介

前文提到了相应式编程，相应式规范Reactive streams，以及相应式扩展Reactor的简单使用
在使用Reactor时我不停很好奇，它是怎么做到的？
好奇心驱策我想要自己去写一个Reactive streams的实现，并参照Reactor源码来看看大神是怎样实现的
话不多说，开始写代码(本文比力啰嗦，由于掺杂了自己的实现思绪)
简单序列的发布者

看一下Reactor的一个简单例子