Android: уведомление о завершении всех асинхронных вызовов.

Я застрял в одной реализации. Я разрабатываю приложение для Android, в которое я интегрировал сторонний SDK (библиотеку) и вызываю его API. Вызов функций SDK на самом деле является асинхронными вызовами (вызовами WebAPI, вызываемыми библиотекой), которые дают ответ (успешно или неудачно).

Теперь я пытаюсь объяснить ситуацию кодом.

for (................) {
    AsyncAPICall (SuccessListener { 
        onSuccess() {
            for (................) {
                AsyncAPICall (SuccessListener { 
                    onSuccess() {
                        for (................) {
                            AsyncAPICall (SuccessListener, ErrorListener);
                        }
                    }
                }, ErrorListener);
            }
        }
    }, ErrorListener);
}

Я хочу получить уведомление или обратный вызов или получить информацию о том, что все асинхронные вызовы завершены. Асинхронные вызовы выполняются в другом потоке, и из-за цикла for многие вызовы будут выполняться одновременно.

Есть ли какой-либо механизм, который информирует меня, как только все асинхронные вызовы получили ответы, или мне нужно что-то сделать вручную?

Любая помощь?


person Khushbu Shah    schedule 23.11.2017    source источник


Ответы (1)


@Khushbu Shah, я обновил свой ответ, он немного изменился :) (он довольно длинный).
Чтобы убедиться, что он работает, я создал отдельный рабочий пример и использовал этот API для тестирования: https://jsonplaceholder.typicode.com/posts/1

private final Retrofit retrofit = new Retrofit.Builder()
            .baseUrl("https://jsonplaceholder.typicode.com/posts/")
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .build();

    private final RestPostsService restPostsService = retrofit.create(RestPostsService.class);

    private Observable<Posts> getPostById(int id) {
        return restPostsService.getPostsById(id);
    }

Решение 1. Используйте при последовательном вызове нескольких задач, результат выполнения предыдущих задач всегда является вводом для следующей задачи

getPostById(1)
                .concatMap(posts1 -> {
                    //get post 1 success
                    return getPostById(posts1.getId() + 1);
                })
                .concatMap(posts2 -> {
                    //get post 2 success
                    return getPostById(posts2.getId() + 1);
                })
                .concatMap(posts3 -> {
                    //get post 3success
                    return getPostById(posts3.getId() + 1);
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(finalPosts -> {
                    //get post 4 success
                    Toast.makeText(this, "Final result: " + finalPosts.getId() + " - " + finalPosts.getTitle(),
                            Toast.LENGTH_LONG).show();
                });

Решение 2: Используйте при последовательном вызове нескольких задач, все результаты предыдущих задач являются входными данными для последней задачи (например: после загрузки изображения аватара и изображения обложки , вызовите API, чтобы создать нового пользователя с этими URL-адресами изображений):

Observable
                .zip(getPostById(1), getPostById(2), getPostById(3), (posts1, posts2, posts3) -> {
                    //this method defines how to zip all separate results into one
                    return posts1.getId() + posts2.getId() + posts3.getId();
                })
                .flatMap(finalPostId -> {
                    //after get all first three posts, get the final posts,
                    // the final posts-id is sum of these posts-id
                    return getPostById(finalPostId);
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(finalPosts -> {
                    Toast.makeText(this, "Final posts: " + finalPosts.getId() + " - " + finalPosts.getTitle(),
                            Toast.LENGTH_SHORT).show();
                });

Манифест Android

 <uses-permission android:name="android.permission.INTERNET"/>

корневой файл build.gradle

// Top-level build file where you can add configuration options common to all sub-projects/modules.

buildscript {
    repositories {
        jcenter()
    }
    dependencies {
        classpath 'com.android.tools.build:gradle:2.3.3'
        classpath 'me.tatarka:gradle-retrolambda:3.2.0'
        classpath 'me.tatarka.retrolambda.projectlombok:lombok.ast:0.2.3.a2'

        // NOTE: Do not place your application dependencies here; they belong
        // in the individual module build.gradle files
    }

    // Exclude the version that the android plugin depends on.
    configurations.classpath.exclude group: 'com.android.tools.external.lombok'
}

allprojects {
    repositories {
        jcenter()
    }
}

task clean(type: Delete) {
    delete rootProject.buildDir
}

приложение/build.gradle

apply plugin: 'me.tatarka.retrolambda'
apply plugin: 'com.android.application'

android {
    compileSdkVersion 26
    buildToolsVersion "26.0.1"
    defaultConfig {
        applicationId "app.com.rxretrofit"
        minSdkVersion 15
        targetSdkVersion 26
        versionCode 1
        versionName "1.0"
        testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"
    }
    buildTypes {
        release {
            minifyEnabled false
            proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
        }
    }

    compileOptions {
        sourceCompatibility JavaVersion.VERSION_1_8
        targetCompatibility JavaVersion.VERSION_1_8
    }
}

dependencies {
    compile fileTree(dir: 'libs', include: ['*.jar'])
    androidTestCompile('com.android.support.test.espresso:espresso-core:2.2.2', {
        exclude group: 'com.android.support', module: 'support-annotations'
    })
    compile 'com.android.support:appcompat-v7:26.+'
    compile 'com.android.support.constraint:constraint-layout:1.0.2'
    testCompile 'junit:junit:4.12'

    provided 'org.projectlombok:lombok:1.16.6'
    compile 'com.squareup.retrofit2:retrofit:2.3.0'
    compile 'com.squareup.retrofit2:converter-gson:2.3.0'
    compile 'com.squareup.retrofit2:adapter-rxjava:2.3.0'
    compile 'io.reactivex:rxandroid:1.2.1'
}

модель

package app.com.rxretrofit;
import com.google.gson.annotations.SerializedName;
/**
 * -> Created by Think-Twice-Code-Once on 11/26/2017.
 */
public class Posts {
    @SerializedName("userId")
    private int userId;
    @SerializedName("id")
    private int id;
    @SerializedName("title")
    private String title;
    @SerializedName("body")
    private String body;
    public int getUserId() {
        return userId;
    }
    public void setUserId(int userId) {
        this.userId = userId;
    }
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getTitle() {
        return title;
    }
    public void setTitle(String title) {
        this.title = title;
    }
    public String getBody() {
        return body;
    }
    public void setBody(String body) {
        this.body = body;
    }
}

RestPostService.java

package app.com.rxretrofit;

import retrofit2.http.GET;
import retrofit2.http.Path;
import rx.Observable;

/**
 * -> Created by Think-Twice-Code-Once on 11/26/2017.
 */

public interface RestPostsService {

    @GET("{id}")
    Observable<Posts> getPostsById(@Path("id") int id);
}

Кстати, использование шаблона Rx + Retrofit + Dagger + MVP — отличное сочетание.

person Think Twice Code Once    schedule 23.11.2017
comment
Я согласен, что rxjava был бы здесь хорош, но ваш пример едва ли имеет смысл, ожидаемые zip(),ObservOn() и subscribeOn(), по крайней мере - person Tim; 23.11.2017
comment
Спасибо @Think Twise Code Once. Сначала я понимаю RxJava, а после этого попробую это решение. - person Khushbu Shah; 23.11.2017
comment
@TimCastelijns Я взглянул на Observable.zip(), прежде чем дать этот ответ, но я думаю, что это решение более простое. - person Think Twice Code Once; 23.11.2017
comment
если вы думаете, что это хорошее решение, вы не знаете, как работает rxjava - person Tim; 23.11.2017
comment
возможно вы правы, я постараюсь углубиться в этом случае, я ожидаю от вас лучшего ответа. - person Think Twice Code Once; 23.11.2017
comment
в этом случае я ожидаю, что вы удалите свой ответ - person Tim; 23.11.2017
comment
Я думаю, что этот ответ очень поможет мне. По крайней мере, отсюда я получил намек на RxJava и теперь буду этому учиться. @ Тим, если у тебя есть точный ответ, ты можешь дать, но подсказка тоже подойдет, когда ты застрял и ответа нет. - person Khushbu Shah; 23.11.2017
comment
@KhushbuShah Вы можете взглянуть на мой обновленный ответ, скажите мне, если вы не можете заставить его работать должным образом. - person Think Twice Code Once; 26.11.2017
comment
Да конечно. Спасибо. Я постараюсь и дам вам знать. - person Khushbu Shah; 29.11.2017