理解线程模型

Streams
  .range(1, 100)
  .dispatchOn(Environment.sharedDispatcher()) //2
  .subscribeOn(Environment.workDispatcher()) //1
  .consume(); //3
Streams
  .range(1, 100)
  .process(RingBufferProcessor.create()) //2
  .subscribeOn(Environment.workDispatcher()) //1
  .capacity(1); //3
  .consume(); //4