将图像加载asynctask转换为rxjava，为什么会滞后ui？

Question

我正在尝试学习 RxJava，我正在转换 AsyncTask 我必须成为 Observable/Subscriber。原来的AsyncTask在后台加载了一张图片，然后在onPostExecute中为加载的图片设置了一个ImageView的drawable。显示的图像在回收视图中，并且随着列表滚动，为列表中的每个项目加载图像。我将它转换为 Rx，但现在滚动时有很多滞后。每次在 RecyclerView 的适配器中调用 onBind 时，都会调用方法 fetchThumbnail。下面你会看到我原来的实现被注释掉了，新的实现。使用 RxJava 时，我发现内存或 CPU 使用率没有显着增加。我相信我也在订阅和观察正确的线程。什么给了？

public class ThumbnailWorker {

    public static void fetchThumbnail(final Context context, final GalleryItem galleryItem, final int thumbId, final ThumnailFetchedListener completionListener) {

        galleryItem.thumbnail.setImageBitmap(null);
        galleryItem.progressBar.setVisibility(View.VISIBLE);

        Observable.just(MediaStore.Video.Thumbnails.getThumbnail(context.getContentResolver(),
                thumbId
                , MediaStore.Video.Thumbnails.MINI_KIND,
                null))
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<Bitmap>() {
                    @Override
                    public void call(Bitmap bitmap) {
                        completionListener.thumbnailFetched(galleryItem, bitmap, thumbId);
                        galleryItem.progressBar.setVisibility(View.GONE);
                    }
                });


//
//        new AsyncTask<Void,Bitmap,Bitmap>() {
//
//
//            @Override
//            protected void onPreExecute() {
//                super.onPreExecute();
//                galleryItem.thumbnail.setImageBitmap(null);
//                galleryItem.progressBar.setVisibility(View.VISIBLE);
//            }
//
//            @Override
//            protected Bitmap doInBackground(Void... params) {
//                Bitmap bitmap = MediaStore.Video.Thumbnails.getThumbnail(context.getContentResolver(),
//                        thumbId
//                        ,MediaStore.Video.Thumbnails.MINI_KIND,
//                        null
//                );
//
//                return bitmap;
//            }
//
//
//            @Override
//            protected void onPostExecute(Bitmap bitmap) {
//                super.onPostExecute(bitmap);
//                completionListener.thumbnailFetched(galleryItem, bitmap,thumbId);
//                galleryItem.progressBar.setVisibility(View.GONE);
//
//            }
//        }.execute();


    }
}

这就是听众所做的一切。侦听器回调适配器。

@Override
public void thumbnailFetched(GalleryItem item, Bitmap thumbnail, int thumbId) {
    if(thumbId == item.id) {
        item.thumbnail.setImageBitmap(thumbnail);
    }
}

Answer 1

Observable.just 可用于已计算的值。

我假设此调用 MediaStore.Video.Thumbnails.getThumbnail(...) 处理您的图像，因此可能会滞后您的 UI。你必须推迟你的电话。为此，您可以使用Observable.fromCallable：

  Observable.fromCallable(() -> MediaStore.Video.Thumbnails.getThumbnail(context.getContentResolver(), thumbId                 , MediaStore.Video.Thumbnails.MINI_KIND, null))
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(bitmap -> {
                    completionListener.thumbnailFetched(galleryItem, bitmap, thumbId);
                    galleryItem.progressBar.setVisibility(View.GONE);
            });

Answer 2

UI阻塞的原因是just(...)运算符中的表达式是在当前线程中执行的。

如果要在subscribeOn(..) 中指定的线程中执行表达式，则必须使用create(..) 方法创建Observable，而不是just(..) 方法。

对你来说，它看起来像这样：

Observable.create(new Observable.OnSubscribe<Bitmap>(){
        @Override
        public void call(Subscriber<? super Bitmap> subscriber){
            subscriber.onNext(MediaStore.Video.Thumbnails.getThumbnail(context.getContentResolver(),
                    thumbId
                    , MediaStore.Video.Thumbnails.MINI_KIND,
                    null));

            subscriber.onCompleted();
        }
    })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1<Bitmap>() {
                @Override
                public void call(Bitmap bitmap) {
                    completionListener.thumbnailFetched(galleryItem, bitmap, thumbId);
                    galleryItem.progressBar.setVisibility(View.GONE);
                }
            });