从不同的调度程序中设置和读取rxJava链中的实例变量值

Question

我不确定使用不同的调度程序从rxJava链读/写实例变量的安全性。有一个小例子

public class RxJavaThreadSafety {

    private int variable = 0;

    // First call 
    public void doWriting() {
        Single.just(255)
                .doOnSuccess(
                        newValue -> variable = newValue
                )
                .subscribeOn(Schedulers.io())
                .subscribe();
    }

    // Second call
    public void doReadingRxChain() {
        Single.fromCallable((Callable<Integer>) () -> variable)
                .subscribeOn(Schedulers.computation())
                .subscribe(
                        result -> System.out.println(result)
                );
    }

    // Third call
    public void doReading() {
        System.out.println(variable);
    }

}

为了简单起见，让我们假设这三个方法一个接一个地调用

我的问题：在io调度程序中设置变量，然后最近从计算调度程序或主线程中读取该变量是否安全？

我认为这不是线程安全的，但我希望一些rxJava和并发专家来证明这一点

Answer 1

不，这不是线程安全的。

当您使用subscribeon时，这意味着调用subscribe()将生成项的任务添加到调度程序的工作队列中。

dowriting()和doreadingrxchain()方法将任务添加到不同的计划程序。不能保证dowriting()中的链甚至会在doreadingrxchain()之前开始运行。例如，如果所有IO线程都忙，就会发生这种情况。

还有一个更根本的问题：您正在一个线程中写入变量的值，并在另一个线程中读取它。如果没有任何并发控制，就无法保证variable的新值被读取它的线程看到。解决此问题的一种方法是将变量声明为volatile:

private volatile int variable = 0;