使用Rx运行周期性任务的好方法是什么，并且只有一个并发执行限制？

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

import java.util.concurrent.TimeUnit;

public class RxPeriodicTask {
    public static void main(String[] args) throws InterruptedException {
        int maxConcurrentTasks = 1; // 设置最大并发任务数

        Observable.interval(1, TimeUnit.SECONDS)
                .flatMapSingle(tick -> performTask(tick), maxConcurrentTasks)
                .subscribeOn(Schedulers.io())
                .observeOn(Schedulers.single())
                .subscribe(
                        result -> System.out.println("Task completed with result: " + result),
                        error -> System.err.println("Task failed with error: " + error.getMessage())
                );

        Thread.sleep(10000); // 让程序运行10秒
    }

    private static Single<String> performTask(long tick) {
        return Single.fromCallable(() -> {
            System.out.println("Task started at tick: " + tick);
            // 模拟任务执行时间
            Thread.sleep(2000);
            System.out.println("Task finished at tick: " + tick);
            return "Result of task " + tick;
        });
    }
}