1

В android есть необходимость выполнять любые взаимодействия с "Интернетом" в другом потоке, но иногда есть нужда всё же подождать результата от сервера и далее что-то с этим делать и конечно же хотелось бы не городить всяких лишних костылей в основном коде для взаимодействия с View компонентами. Немного подумав решил сделать нечто подобное:

private void initRequest(){

    final Handler handler = new Handler(){
        public void handleMessage(android.os.Message msg) {
            Toast.makeText(MainActivity.this, (String) msg.obj, Toast.LENGTH_LONG).show();
        };
    };

    Thread thread = new Thread(new Runnable() {
        @Override
        public void run() {
            Message message;

            if(Utils.isNetworkConnected(MainActivity.this)){
                HttpClient httpclient = new DefaultHttpClient();

                HttpGet httpGet = new HttpGet(INIT_HOST);

                httpGet.addHeader("Content-Type", "application/json");

                try {
                    HttpResponse httpResponse = httpclient.execute(httpGet);

                    String strEntity = EntityUtils.toString(httpResponse.getEntity());

                    JSONObject jsonObject = new JSONObject(strEntity);

                    Global_Variables.COORDS_INTERVAL = jsonObject.getInt(Constance.INIT_RECORD_INTERVAL);
                    Global_Variables.POST_INTERVAL = jsonObject.getInt(Constance.INIT_SEND_INTERVAL);
                    Global_Variables.TIME_CHECK_SPEED = jsonObject.getInt(Constance.INIT_SPEED_INTERVAL);
                    Global_Variables.TRIGGER_SPEED = jsonObject.getInt(Constance.INIT_TRIGGER_SPEED);
                } catch (ClientProtocolException e) {
                    message = new Message();
                    message.obj = "Failed send init request!";
                    handler.sendMessage(message);
                } catch (IOException e) {
                    message = new Message();
                    message.obj = "Unsuccessful receiving entity!";
                    handler.sendMessage(message);
                } catch (JSONException e) {
                    message = new Message();
                    message.obj = "Failed parse Json!";
                    handler.sendMessage(message);
                }
            }else{
                message = new Message();
                message.obj = "Check Internet connection!";
                handler.sendMessage(message);
            }
        }
    });

    thread.setName("Init request");

    thread.start();

    try {
        thread.join();
    } catch (InterruptedException e) {
        throw new RuntimeException("Thread "+thread.getName()+" interrupted!");
    }

}

За пример взял один из функционалов моего приложения. В сам выполняемый функционал вдаваться смысла не вижу, хотелось бы обратить внимание на такие моменты как: Handler (необходимый для взаимодействия с UI потоком), и метод join() для потока, который необходим, чтобы указать потоку, в котором мы стартовали поток thread, что ему необходимо дождаться завершения потока thread, это необходимо для того, чтобы глобальные данные до этого никто не успел заюзать. Что всё это даёт? А то, что вы спокойно выполняете метод в другом потоке без лишнего кода в основном коде и при всём этом главный поток ожидает вашего завершения, а в результате ещё и можете провзаимодействовать с UI потоком. Единственным недостатком всего этого вижу то, что результат имеет смысл слать только под конец потока ибо если это сделать в середине, то код в handler не выполнится из-за join(), пока весь поток не проделает работу до конца. А теперь вопрос: что вы обо всём этом думаете, придумал ли я интересный способ или написал какую-то чушь?

6
  • Чем AsyncTask не подошёл? 22 янв 2016 в 9:19
  • 2
    Уже есть готовые библиотеки для работы с сетью, например retrofit square.github.io/retrofit он инкапсулирует всю логику по обеспечению асинхронности, парсингу данных и предлагает удобные коллбэки для уведомления ui, есть поддержка выполнения синхронных запросов 22 янв 2016 в 9:22
  • @Suvitruf AsyncTask разве стопит основной поток, чтобы тот подождал завершения основного потока?
    – BORSHEVIK
    22 янв 2016 в 9:29
  • стопить основной поток нельзя. Это очень ужасно. 22 янв 2016 в 10:49
  • @metalurgus Вы скорее всего правы, при длительной операции я могу словить ANR
    – BORSHEVIK
    22 янв 2016 в 11:04

2 ответа 2

1

Хороший вопрос, интересное решение. Тоже всегда было самому интересно кто и как справляется с этой задачей, в дополнение лишь распишу как реализую это я. У меня есть свой класс CallBack:

public class CallBack<T> {
    public void onSuccess() {
    }

    public void onSuccess(T result) {
    }

    public void onFail(String message) {

    }

    public void onFailure(T result) {

    }

}

Для работы с API методами для GET И POST запросов я использую библиотеку android-async-http. На мой взгляд одна из самых лучших либ, которая постоянно обновляется и развивается. К примеру есть метод на получение списка неких объектов:

public static void getTestObjectsList(final String url, final Context context, final CallBack<ArrayList<TestObject>> callBack) {

        if (!Server.isOnline(context)) {
            callBack.onFail(context.getString(R.string.no_internet_error));
            return;
        }


        Server.getAsyncHttpClient(context).get(url, new JsonHttpResponseHandler() {

            @Override
            public void onSuccess(int statusCode, Header[] headers, JSONArray jsonArray) {

                ArrayList<TestObject> testObjects = new ArrayList<>();

                if (!(jsonArray.length() > 0)) {
                    callBack.onSuccess(testObjects);
                    return;
                }

                for (int i = 0; i < jsonArray.length(); i++) {
                    try {
                        JSONObject jsonObject = jsonArray.getJSONObject(i);
                        TestObject testObject = new TestObject();
                        testObject.setId(jsonObject.getInt("id"));
                        testObject.setTitle(jsonObject.getString("title"));
                        testObject.setDescription(jsonObject.getString("description"));

                        testObjects.add(testObject);
                    } catch (JSONException e) {
                        e.printStackTrace();
                    }
                }

                callBack.onSuccess(testObjects);

            }

            @Override
            public void onFailure(int statusCode, Header[] headers, Throwable throwable, JSONObject errorResponse) {
                callBack.onFail(errorResponse.getString("error"));
            }
        });

    }

Где Server.getAsyncHttpClient(context) возвращает new AsyncHttpClient(). Вся эта штука выполняется в отдельном потоке и в отдельном классе. Я люблю использовать такой подход: если есть, к примеру, объект TestObject, то все операции, которые происходят с ним я описываю в классе TestObjectManager.

Как я это использую. К примеру вызываю в своем Activity запрос:

TestObjectManager.getTestObjectsList(url, getApplicationContext(), new CallBack<ArrayList<TestObject>>() {
            @Override
            public void onSuccess(ArrayList<TestObject> testObjects) {
              //сюда приходит положительный результат. Здесь можно установить адаптер, скрыть прогресс бар и т.д. 
            }

            @Override
            public void onFail(String error) {
               showShortMessage(error);//здесь просто показываем ошибку в случае неудачи
            }
    });

Как мы видим, этот код дожидается результата от выполнения запроса, и в любом случае его получит, будь он положительный или отрицательный. Вообще надеюсь поделился опытом по делу) И! жду конструктивной критики)

3
  • Ваше решение тоже довольно интересное
    – BORSHEVIK
    22 янв 2016 в 9:44
  • для всего этого уже есть готовое решение в retrofit или можно просто использовать OkHttp 22 янв 2016 в 9:47
  • @nick_kryloff а в чем принципиальное отличие okhttp от asynchttp? 22 янв 2016 в 9:52
0

Нельзя блокировать main thred больше чем на 5 сек, андройд расценит это как anr и грохнит таску

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.