使用BackpressureStrategy的RxJava2 Flowable.create blockingSubscribe语义

是指在使用RxJava2中的Flowable.create方法创建Flowable时，通过指定BackpressureStrategy来处理背压（Backpressure）问题，并使用blockingSubscribe方法进行订阅。

背压是指当生产者产生的数据速度快于消费者处理数据的速度时，需要一种机制来控制数据流的速度，以避免消费者被淹没或内存溢出等问题。RxJava2提供了不同的BackpressureStrategy来处理不同的背压情况。

在Flowable.create方法中，可以通过指定BackpressureStrategy来选择不同的背压策略，其中包括：

1. BackpressureStrategy.ERROR：当生产者产生的数据速度快于消费者处理数据的速度时，会抛出MissingBackpressureException异常，表示背压错误。
2. BackpressureStrategy.BUFFER：当生产者产生的数据速度快于消费者处理数据的速度时，会将数据缓存到一个无限大的缓冲区中，直到消费者处理完毕。
3. BackpressureStrategy.DROP：当生产者产生的数据速度快于消费者处理数据的速度时，会丢弃一部分数据，以保持数据流的稳定。
4. BackpressureStrategy.LATEST：当生产者产生的数据速度快于消费者处理数据的速度时，会丢弃之前产生的数据，只保留最新的数据。

使用blockingSubscribe方法可以进行阻塞式的订阅，即在订阅时会阻塞当前线程，直到数据流处理完毕或发生错误。

推荐的腾讯云相关产品：腾讯云云函数（Serverless Cloud Function），它是一种无需管理服务器即可运行代码的计算服务，可用于处理各种事件驱动的任务，包括异步消息处理、数据处理、定时任务等。腾讯云云函数支持Java语言和RxJava2库，可以方便地使用RxJava2进行异步编程和处理背压问题。

产品介绍链接地址：腾讯云云函数