简单的Rx示例阻塞或具有争用条件

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class RxExample {
    public static void main(String[] args) {
        // 创建一个Observable，发出1到5的整数序列
        Observable<Integer> observable = Observable.range(1, 5);

        // 使用flatMap操作符将每个整数转换为一个延迟1秒的Observable
        // 并在每个Observable上执行耗时操作
        observable.flatMap(i ->
                Observable.just(i)
                        .subscribeOn(Schedulers.computation())
                        .map(RxExample::performTask)
        )
        // 订阅观察者来处理结果
        .subscribe(System.out::println);

        // 等待一段时间，以便观察者有足够的时间处理所有事件
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    // 模拟一个耗时操作
    private static int performTask(int i) {
        try {
            // 模拟耗时操作
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return i * 2;
    }
}