reactor-核心

永远别独自展开异步工作。
— Jon Brisbin
在写 Reactor 1 之后

永远别独自展开异步工作。
— Stephane Maldini
在写 Reactor 2 之后

先来看看，某项目是如何使用 Groovy 的：

  1. // 初始化上下文，获取默认调度者
  2. Environment.initialize()
  4. // RingBufferDispatcher，默认带 8192 槽容量
  5. def dispatcher = Environment.sharedDispatcher()
  7. // 创建回调
  8. Consumer<Integer> c = { data ->
  9.         println "some data arrived: $data"
  10.     }
  12. // 创建 error 回调
  14. Consumer<Throwable errorHandler = { it.printStackTrace }
  16. // 异步分发数据
  17. dispatcher.dispatch(1234, c, errorHandler)
  19. Environment.terminate()

然后，再看看响应式数据流例子

  1. // 独立异步处理者
  2. def processor = RingBufferProcessor.<Integer>create()
  4. // 发送数据，确保数据的安全性，直到订阅成功
  5. processor.onNext(1234)
  6. processor.onNext(5678)
  8. // 消费整型数据
  9. processor.subscribe(new Subscriber<Integer>(){
  11.   void onSubscribe(Subscription s){
  12.       //unbounded subscriber
  13.       s.request Long.MAX
  14.   }
  16.   void onNext(Integer data){
  17.       println data
  18.   }
  20.   void onError(Throwable err){
  21.       err.printStackTrace()
  22.   }
  24.   void onComplete(){
  25.       println 'done!'
  26.   }
  27. }
  29. // 完全关闭内部线程和调用
  30. processor.onComplete()