rxjava学习笔记

使用第二种代替第一种

//1.开启子线程处理，防止在处理过量数据时出现ANR
        new Thread(() -> {
            allKeyDao.deleteAll();
            sourceDao.deleteAll();
        }).start();
        //2.使用rxjava处理耗时操作
        Observable.create(emitter -> {
            allKeyDao.deleteAll();
            sourceDao.deleteAll();
        }).subscribeOn(Schedulers.io()).subscribe();