我對(duì) RxJava2 有愚蠢的問(wèn)題。我需要同時(shí)運(yùn)行兩個(gè)長(zhǎng)時(shí)間的操作。我知道我應(yīng)該使用 Observable.zip() 并且我使用了它。問(wèn)題是我的長(zhǎng)期操作一個(gè)接一個(gè)地運(yùn)行，另一個(gè)問(wèn)題是我的長(zhǎng)期操作在我訂閱它們之前就開(kāi)始了。假設(shè)這是我應(yīng)該異步運(yùn)行的長(zhǎng)期操作。private String doSomethingLong() {        Random rand = new Random();        int value = rand.nextInt(5);        Timber.i("Do something for [%d] sec [%s]", value, Thread.currentThread().getName());        try {            Thread.sleep(value * 1000);        } catch (InterruptedException e) {            e.printStackTrace();            return String.format(Locale.getDefault(), "Exception [%s]", e.getMessage());        }        return String.format(Locale.getDefault(),"Job for [%d] seconds", value);    }并讓有一個(gè)像 test() 這樣的方法來(lái)嘗試使其并行：public void test() {        final long started = System.currentTimeMillis();        Observable<String> just1 = Observable.just(doSomethingLong()).subscribeOn(Schedulers.newThread());        Observable<String> just2 = Observable.just(doSomethingLong()).subscribeOn(Schedulers.newThread());        Observable.zip(just1, just2, new Func2<String, String, Combined>() {            @Override            public Combined call(String s, String s2) {                return new Combined(s, s2);            }        }).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<Combined>() {            @Override            public void onCompleted() {            }            @Override            public void onError(Throwable e) {            }            @Override            public void onNext(Combined combined) {                long total = System.currentTimeMillis() - started;                Timber.i("TOTAL [%d]ms [%s]", total, combined.toString());            }        });    }當(dāng)我嘗試運(yùn)行它時(shí)，我觀察到兩個(gè)可觀察對(duì)象 just1 和 just2 一個(gè)接一個(gè)地運(yùn)行……這讓我很困惑……但是還有另一個(gè)工作人員讓我更加困惑......我評(píng)論了 Observable.zip 并注意到 just1 和 just2 在我訂閱它們之前啟動(dòng)了方法 doSomethingLong() ......