java 9 在 java.util.concurrent.flow 包下引入了响应式流，支持可互操作的发布-订阅 框架。它跨越异步边界处理异步数据流（将元素传递到另一个线程或线程池），并且接收方不会被迫缓冲任意数量的数据，因此不会发生缓冲区溢出。
flow api包含四个相互关联的核心接口：发布者、订阅者、订阅和处理器。语法@functionalinterfacepublic static interface publisher<t> { public void subscribe(subscriber<? super t> subscriber)}public static interface subscriber<t> { public void onsubscribe(subscription subscription); public void onnext(t item); public void onerror(throwable throwable); public void oncomplete();}public static interface subscription { public void request(long n); public void cancel();}public static interface processor<t, r> extends subscriber<t>, publisher<r> {}
这四个接口：flow.publisher、flow.processor、flow.subscriber 和 flow 。与反应流规范相关的订阅。 发布者接口有subscribe()方法，订阅有cancel()和request() 方法，订阅者有 onsubscribe()、onnext()、onerror() 和 >oncomplete() 方法。 处理器接口实现flow的所有方法。发布者和flow.subscriber 接口。
以上就是java 9中的reactive streams的核心接口是什么？的详细内容。