rxjava多线程并行执行任务

并行执行是将.subscribeOn(Schedulers.~~~）写在flatmap里面。

    val executor = Executors.newFixedThreadPool(10)
    Observable.range(0, 20)
            .flatMap { i ->
                Observable.create<Int>({ e -> e.onNext(sleep(i)) })
                        .subscribeOn(Schedulers.from(executor))
            }

这样给每一个任务分别指定执行线程，注意这里如果不使用线程池Schedulers.from(executor)，而是Schedulers.newThread()，io()等，会给每一个任务都开线程，任务太多的话，资源不够，程序可能崩溃

如果写在flatmap外面：

fun main(args: Array<String>) {
    val executor = Executors.newFixedThreadPool(10)
    Observable.range(0, 20)
            .flatMap { i -> Observable.create<Int>({ e -> e.onNext(sleep(i)) }) }
            .subscribeOn(Schedulers.from(executor))
            .subscribe { i -> println(i) }

}
fun sleep(i : Int): Int{
    Thread.sleep(100)
    return i
}

``
打印顺序是0,1,2,3,...。用时2秒

并行执行

fun main(args: Array<String>) {
    val executor = Executors.newFixedThreadPool(10)
    Observable.range(0, 20)
            .flatMap { i -> 
                Observable.create<Int>({ e -> e.onNext(sleep(i)) })
                        .subscribeOn(Schedulers.from(executor)) 
            }
            .subscribe { i -> println(i) }

}
fun sleep(i : Int): Int{
    Thread.sleep(100)
    return i
}

``
打印是出的字符无序的，用时0.3秒