如何确保rxjava方法并行执行并完成？

Observable.just(1, 2, 3)
    .flatMap(num -> Observable.just(num)
        .subscribeOn(Schedulers.computation())
        .map(this::performTask))
    .subscribe(result -> {
        // 处理并行执行后的结果
    });

Observable.just(1, 2, 3)
    .flatMap(num -> Observable.just(num)
        .subscribeOn(Schedulers.computation())
        .map(this::performTask))
    .toList()
    .subscribe(results -> {
        // 处理并行执行后的结果列表
    });

Observable.just(1, 2, 3)
    .concatMapEager(num -> Observable.just(num)
        .subscribeOn(Schedulers.computation())
        .map(this::performTask))
    .toList()
    .subscribe(results -> {
        // 处理并行执行后的结果列表
    });