避免在 Android 应用中的 Android Volley 中出现 Race condition

Question

我是 Android Development 的新手，我正在尝试开发我的第一个 Android 应用程序，该应用程序使用 Android Volley.[=28 从一些 public APIs 获取数据=]

我正在使用在启动器 activity 中初始化的 singleton Volley Request Queue。当我在 Volley's JsonObjectRequest 中设置我的 RecyclerView 适配器时，我能够成功地解析 JSON 内容并将它们显示在 Fragment layout/view (uses RecyclerView & CardView) 上。

以下代码确实显示数据，但存在时间竞争条件。注：RvJoiner 是一个合并多个适配器并使单个适配器按先到先得顺序排列的库。

我的片段class如下：

public class Fragment1 extends Fragment {

@Override
public View onCreateView(LayoutInflater inflater, ViewGroup container,
                         Bundle savedInstanceState) {
    View v = inflater.inflate(R.layout.recylcer_main, container, false);
    ParseJSON parseJSON = new ParseJSON(v);
    parseJSON.makeRequest1();
    parseJSON.makeRequest2();

    return v;
   }
}

我的ParseJSON class如下

public class ParseJSON {

private static final String URL1 = "some url";
private static final String URL2 = "some other url";
private static final String TAG = "ParseJSON";
private RequestQueue requestQueue;

private boolean FLAG_REQUEST1_FETCHED;
private boolean FLAG_REQUEST2_FETCHED;

private ArrayList<status1> status1ArrayList;
private ArrayList<status2> status2ArrayList;

private Context context;
private RvJoiner rvJoiner;
private View view;

ProgressDialog pd;

ParseJSON (View v){
    this.view= v;
    this.context=v.getContext();
    pd = ProgressDialog.show(v.getContext(), "Please Wait", "Getting Data from APIs", true);
    requestQueue = AppController.getInstance(v.getContext()).getRequestQueue();
    rvJoiner = new RvJoiner();
}


public void makeRequest1() {
    JsonObjectRequest request1 = new JsonObjectRequest(Request.Method.GET, URL1,
            null, new Response.Listener<JSONObject>() {
        @Override
        public void onResponse(JSONObject response) {

            try {
                /* Parsing Stuff and storing it in status1ArrayList */ 

        FLAG_REQUEST1_FETCHED=true;

                    Status1Adapter status1Adapter = new Status1Adapter(status1ArrayList);
                    RecyclerView recList = (RecyclerView) view.findViewById(R.id.cardList);
                    recList.setLayoutManager(new LinearLayoutManager(context));

                    rvJoiner.add(new JoinableAdapter(status1Adapter));
                    recList.setAdapter(rvJoiner.getAdapter());
                    pd.dismiss();
                }

            } catch (JSONException e) {}
        }

    }, new Response.ErrorListener() {
        @Override
        public void onErrorResponse(VolleyError error) {}
    });
    AppController.getInstance(context).addToRequestQueue(request1);
}

public void makeRequest2() {

    JsonObjectRequest request2 = new JsonObjectRequest(Request.Method.GET, URL2,
            null, new Response.Listener<JSONObject>() {
        @Override
        public void onResponse(JSONObject response) {
            try {
        /* Parsing stuff and storing it inside ArrayList status2ArrayList */

FLAG_REQUEST2_FETCHED=true;

                    Status2Adapter status2Adapter = new Staus2Adapter(status2ArrayList);

                    RecyclerView recList = (RecyclerView) view.findViewById(R.id.cardList);
                    recList.setLayoutManager(new LinearLayoutManager(context));

                    rvJoiner.add(new JoinableAdapter(status2Adapter));
                }

            } catch (JSONException e) {}
        }

    }, new Response.ErrorListener() {
        @Override
        public void onErrorResponse(VolleyError error) {}
    });
    AppController.getInstance(context).addToRequestQueue(request2);
}

public boolean isStatusFetched(){
    return FLAG_REQUEST1_FETCHED && FLAG_REQUEST2_FETCHED;
}

public ArrayList<status1> getstatus1ArrayList() {
    return status1ArrayList;
}


public ArrayList<status2> getstatus2ArrayList() {
    return status2ArrayList;
}
}

在上面的代码中，我遇到了竞争条件。由于 Volley 网络调用本质上是异步的，我无法控制哪个请求将首先完成并显示在我的 Fragment CardView 上。（即可以先执行 rvJoiner.add() 个请求中的任何一个）

我想让我的 UI 保持一致，即我希望首先将 Request1 适配器添加到 RvJoiner，然后再添加 Request2。

如果可能，我想将所有设置适配器并将它们连接起来的代码从 JsonObjectRequest 移动到我的 Fragment 的 onCreateView 方法。因此，通过这种方式，我可以控制适配器的顺序。但是，然后我需要一种方法来通过 isStatusFetched 方法连续检查 FLAG_REQUEST1_FETCHED 和 FLAG_REQUEST2_FETCHED 的值。

片段代码 class 将是

public class Fragment1 extends Fragment {

@Override
public View onCreateView(LayoutInflater inflater, ViewGroup container,
                         Bundle savedInstanceState) {
    View v = inflater.inflate(R.layout.recylcer_main, container, false);
    ParseJSON parseJSON = new ParseJSON(v);
    parseJSON.makeRequest1();
    parseJSON.makeRequest2();

while(!parseJSON.isDataFetched()){
/* I want to wait here till both status1ArrayList and status2ArrayList gets     populated with data in ParseJSON. In this way I can control the order in which adapters are added inside RvJoiner. If I don't wait here I will get NullPointerException on runtime since Volley calls are asynchronous and getStatus1ArrayList/getStatus2ArrayList will most probably return null. But how to wait here without consuming too much CPU power? */
}

    ArrayList<status1> status1ArrayList = parseJSON.getstatus1ArrayList();
    ArrayList<status2> status2ArrayList = parseJSON.getstatus2ArrayList();  

    Status1Adapter status1Adapter = new Status1Adapter(status1ArrayList);
    Status2Adapter status2Adapter = new Status2Adapter(status2ArrayList);

    RecyclerView recList = (RecyclerView) v.findViewById(R.id.cardList);
    recList.setLayoutManager(new LinearLayoutManager(v.getContext()));

RvJoiner rvJoiner = new RvJoiner();
/* Problem solved as I'm adding adapters in the order I want */
    rvJoiner.add(new JoinableAdapter(status1Adapter)); 
    rvJoiner.add(new JoinableAdapter(status2Adapter));

    recList.setAdapter(rvJoiner.getAdapter());
    return v;
}

}

一种解决方案是使用回调。我在某个地方读到过它们，但我不确定它是否解决了我的 'multiple request at the same time while maintaining order'.

问题

另一种解决方案是限制我的 Volley 队列一次只能处理一个请求，但这会增加获取和提供数据所需的时间。这是我最后的选择。

我几乎没有想法，希望有人能帮助我，以便我可以控制设置我的适配器的顺序并保持一致 UI。如果您需要任何其他信息，请告诉我。

谢谢。

Answer 1

这就是避免两个请求竞争条件的一般方法。您应该使用回调。 onResponse 方法的实现是回调，因为这些方法是在一个请求完成后调用的。响应处理在 UI 线程上工作，对吗？因此，响应只能一个接一个地处理。这意味着你只需要在那里维持秩序。得到一个回应后提取你想做的工作。您需要一些布尔标志来指示您的请求是否已完成。伪代码如下所示：

request1Done = false;
request2Done = false;
doRequest1();
doRequest2();
onResponse1() {
    doWorkForRequest1();  // always start handling the response
    request1Done = true;
    if (request2Done) {   // if this is true, request2 was faster than request1
        doWorkForRequest2();
    }
};
onResponse2() {
     request2Done = true;
     if (request1Done) {  // request1 did its work, no its request2's turn
         doWorkForRequest2();
     }
};

所以基本上您应该修复您的 onReponse 方法。希望这会帮助你。 :)

避免在 Android 应用中的 Android Volley 中出现 Race condition

Avoid getting Race condition in Android Volley in Android app

android

asynchronous

race-condition

android-fragments

android-volley