小编Joh*_*eff的帖子

在RxJava中线程安全是否必需SerializedSubject

Subject在RxJava中创建了一个实例,并onNext()从多个线程调用它:

PublishSubject<String> subject = PublishSubject.create();
//...
subject.onNext("A");  //thread A
subject.onNext("B");  //thread B
Run Code Online (Sandbox Code Playgroud)

RxJava文档说:

注意不要onNext(?)从多个线程调用其方法(或其他方法),因为这可能导致非序列化调用,这违反了Observable合约并在结果中产生歧义Subject.

  • 我是否必须打电话toSerialized(),Subject假设我不关心是否"A"在之前或之后"B"?序列化将如何帮助?
  • Subject无论如何都是线程安全的还是我会在没有的情况下破坏RxJava toSerialized()
  • 文件中提到的" 可观察合同 "是什么?

java thread-safety rx-java

10
推荐指数
1
解决办法
2735
查看次数

标签 统计

java ×1

rx-java ×1

thread-safety ×1