设定容量

Stream<String> st;

st
  .dispatchOn(sharedDispatcher())
  .capacity(256) //1
  .consume(s -> service.doWork(s)); //2