RxJava 的 onNext 访问资源时，否需要考虑线程安全。

[fanck0605]

《 RxJava 反应式编程》中有提到（ P7 ），按照契约 Obverser 的 onNext 函数是不会同时被多条线程调用的，这不就意味着不存在对临界资源的争抢。那么后文(P71)又说需要保证 lambda 表达式(total::add)内访问变量的线程安全性。

如果这个资源（total 变量，如果不是 atomic 的)， 只会被这一个 Obverser 访问，那么还需要考虑线程安全问题吗。

P7

p71

[shyling]

下面的例子举的不对。。。

他的意思应该是让最好用 scan 累加结果，而不是用外部的 adder 。。。但这个例子跑起来也没问题。

[shyling]

如果 adder 不线程安全，结果也是对的。onNext 是顺序调用的

[fanck0605]

@shyling
onNext 虽然是顺序调用的, 但需不需要考虑变量不可见 (volatile 关键词) 的问题呢？

毕竟 onNext 并没有保证是在同一条线程运行。

[fanck0605]

我编写了这样的一段代码，虽然不加 volatile 结果是正确的，但是我仍然不确定 volatile 是否是必要的


[chihiro2014]

如果变量是全局的，那就需要加 volatile 。局部就不需要 @fanck0605

[fanck0605]

看了一下 JVM 的 happens-before 规则，onNext 前后好像都有内存屏障，毕竟一定用了锁或者 volatile 变量操作，所以 onNext 内访问的变量，无需加 volatile ，一定安全的。

[aboutlonger]

我猜这个契约是要开发者去遵守的，不是 rxjava 作出的保证。

即使这个资源只会被一个 Observer 访问，也是需要考虑线程安全的，因为一个 Observable 的 Scheduler 可以是一个线程池。