android - 避免在 Android 应用程序的 Android Volley 中出现 Race condition

Question

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

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

以下代码确实显示数据，但存在时间竞争条件。注意:RvJoiner 是一个将多个适配器合并并使单个适配器按先到先服务原则排序的库。

我的 fragment 类如下:

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类如下

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 方法。因此，通过这种方式，我可以控制适配器的顺序。但是，我需要一种方法来检查 FLAG_REQUEST1_FETCHED 的值和 FLAG_REQUEST2_FETCHED通过isStatusFetched方法不断。

fragment 类的代码将是

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;
}

}

一种解决方案是使用回调。我在某处读到过有关它们的信息，但我不确定它是否解决了我的“在保持秩序的同时同时发出多个请求”的问题。

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

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

谢谢。

Answer 1

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

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 方法。希望这会帮助你。 :)