RxJava怎么实现多个线程同时执行,怎么实现retryWhen
这表明同一时间段只能有 1 个线程执行 work 方法，因为 work 方法里的代码需要获取到锁才能执行，这就实现了多个线程间的通信，线程 0 获取锁，先执行，线程 1 等待，线程 0 释放锁，线程 1 继续执行。
一旦 Observable 不再发出 items，它将会调用 Subscriber.onCompleted() 方法，或如果有一个出错的话Observable 会调用 Subscriber.onError() 方法。onNext()： RxJava的事件回调方法，针对普通事件。
才学RxJava的时候还是挺困惑的，感觉有特别多的对『时间』的操作符，比如timer()、interval()、delay()、defer()等等……总之功能太强大，直接吓跑了一群初学者。
通过引入函数式的方式来处理数据流，看起来舒服多了。另外RxJava有大量丰富强大的operator，可以满足你的大部分数据处理需求。
RxJava和EventBus的区别
1、二者区别如下：RxJava有大量丰富强大的operator，可以满足用户的大部分数据处理需求。
2、EventBus是一个Android端优化的publish/subscribe消息总线，简化了应用程序内各组件间、组件与后台线程间的通信。
3、EventBus比较适合仅仅当做组件间的通讯工具使用，主要用来传递消息。使用EventBus可以避免搞出一大推的interface，仅仅是为了实现组件间的通讯，而不得不去实现那一推的接口。
安卓怎么用rxjava实现线程间的传递数据
1、（1）synchronized关键字 在Java中内置了语言级的同步原语synchronized关键字，其在多线程条件下实现了对共享资源的同步访问。根据synchronized关键字修饰的对象不同可以分为以下几种情况。
2、在 RxJava 上，一个 Observable 是一个发出数据流或者事件的类，Subscriber 是一个对这些发出的 items （数据流或者事件）进行处理（采取行动）的类。
3、需要用到安卓跨进程通讯，IPC (进程间通信) 的时候，AndLinker是一款Android上的IPC (进程间通信) 库，结合了 AIDL 和 Retrofit 的诸多特性，且可以与 RxJava 和 RxJava2 的Call Adapters无缝结合使用。
4、线程与线程之间是无法直接通信的，A 线程无法直接通知 B 线程，Java 中线程之间交换信息是通过共享的内存来实现的，控制共享资源的读写的访问，使得多个线程轮流执行对共享数据的操作，线程之间通信是通过对共享资源上锁或释放锁来实现的。
5、在RxJava中，可以通过对Observable连续调用多个Operator组成一个调用链，其中数据从上游向下游传递。当上游发送数据的速度大于下游处理数据的速度时，就需要进行Flow Control了。
6、可以满足你的大部分数据处理需求。RxJava另一个强大的地方就是他的scheduler，你可以为Observable和Subscriber指定不同的执行线程，在Android中，你就可以方便的将Observable指定在IO线程中运行，Subscriber在UI线程中运行。
微信扫一扫 
支付宝扫一扫 
