Android - поток вызовов синхронизируется в потоке пользовательского интерфейса - PullRequest
Новая
       34

Android - поток вызовов синхронизируется в потоке пользовательского интерфейса

0 голосов
/ 20 марта 2019

Я пытаюсь создать синхронизированные потоки, но всегда получаю следующую ошибку: android.os.NetworkOnMainThreadException.

Я прочитал больше постов, но они не работают для меня.

Ниже я пишу блоки кода, которые не работают для меня:

1 

final SyncApp syncJob = new SyncApp();
Thread t = new Thread (new Runnable () {
                         @Override
                         public void run () {
                             synchronized (syncJob) {
                                 String s = syncJob.insert (newJobs, GlobalVariables.URL_LOCALHOST + "jobs");
                                 txtState.setText (s);
                             }}});
                         }
                     });
                     t.Start ();
// t.run ();

2 

myClass.runOnUiThread(new Runnable() {
        public void run() {...}
})

3

Запуск кода в главном потоке из другого потока

SyncApp: 

public class SyncApp {

    synchronized public String insert(List<Jobs> job, String... params) {
        URL url = null;
        HttpURLConnection conn = null;
        try {
            url = new URL(params[0]);
            conn = (HttpURLConnection) url.openConnection();
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setDoInput(true);
            conn.setDoOutput(true);
            String str = new Gson().toJson(job);
            byte[] outputInBytes = str.getBytes();
            OutputStream os = conn.getOutputStream();
            os.write( outputInBytes );
            os.flush();

            int responseCode=conn.getResponseCode();
            String response = null;
            if (responseCode == HttpsURLConnection.HTTP_OK) {
                String line;
                BufferedReader br=new BufferedReader(new InputStreamReader(conn.getInputStream()));
                while ((line=br.readLine()) != null) {
                    response+=line;
                }
            }
            else {
                response=conn.getResponseMessage();

            }
            return response;
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            conn.disconnect();
        }
        return null;
    }
}

Мне нужно вызвать поток, дождаться ответа и вызвать другой поток. Их ответы я должен использовать их в деятельности

Ответы [ 2 ]

0 голосов
/ 04 апреля 2019

Мое решение: 

public class Sync extends AppCompatActivity {

...

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_sync_server);

    dao = new DAO(this);

    txtState = findViewById(R.id.txt_log);

    btnSincro = findViewById(R.id.btn_sincro);
    btnSincro.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            countCall = 0;
            callFlow();
        }
    });

    btnHome = findViewById(R.id.btn_home);
    btnHome.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            Intent intent = new Intent(SyncServerActivity.this, MainActivity.class);
            startActivity(intent);
        }
    });
}

private void callFlow() {
    switch (countCall) {

        case 0:
            templates = toTemplate("url");
            break;

        case 1:
            jobs = toJobs("url");
            break;

        case 2:
            job = ... //select item
            res = sendJobs(jobs, "url");
            break;

        default:
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    btnSincro.setEnabled(true);
                    txtState.append("\n\nEND");
                }
            });
    }
}

private void nextStep() {
    setText(txtState, "\nSync \n" + countCall + "/3");
    countCall++;
    callFlow();
}

private void setText(final TextView text, final String value) {
    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            text.setText(value);
        }
    });
}


public List<Templates> toTemplate(final String... params) {
    final List<Templates> list = new ArrayList<>();
    Thread t = new Thread(new Runnable() {
        @Override
        public void run() {
            URL url = null;
            BufferedReader reader = null;
            HttpURLConnection connection = null;

            try {
                url = new URL(params[0]);
                connection = (HttpURLConnection) url.openConnection();
                connection.connect();

                InputStream stream = connection.getInputStream();

                reader = new BufferedReader(new InputStreamReader(stream));

                int responseCode = connection.getResponseCode();
                String response = null;
                if (responseCode == HttpsURLConnection.HTTP_OK) {
                    StringBuffer buffer = new StringBuffer();
                    String line = "";
                    while ((line = reader.readLine()) != null) {
                        buffer.append(line);
                    }
                    String finalJson = buffer.toString();
                    JSONObject parentObject = new JSONObject(finalJson);
                    JSONArray parentArray = parentObject.getJSONArray("data");
                    for (int i = 0; i < parentArray.length(); i++) {
                        Templates item = new Gson().fromJson(parentArray.get(i).toString(), Templates.class);
                        list.add(item);
                    }
                } else {
                    response = connection.getResponseMessage();
                }

            } catch (MalformedURLException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } catch (JSONException e) {
                e.printStackTrace();
            } finally {
                if (connection != null)
                    connection.disconnect();
                try {
                    if (reader != null)
                        reader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                nextStep(); //call next Thread
            }
        }
    });
    t.start();
    return list;
}

public List<Jobs> toJobs(final String... params) {
    final List<Jobs> list = new ArrayList<>();
    Thread t = new Thread(new Runnable() {
        @Override
        public void run() {
            URL url = null;
            BufferedReader reader = null;
            HttpURLConnection connection = null;
            try {
                url = new URL(params[0]);
                connection = (HttpURLConnection) url.openConnection();
                connection.connect();

                InputStream stream = connection.getInputStream();

                reader = new BufferedReader(new InputStreamReader(stream));

                int responseCode = connection.getResponseCode();
                String response = null;
                if (responseCode == HttpsURLConnection.HTTP_OK) {
                    StringBuffer buffer = new StringBuffer();
                    String line = "";
                    while ((line = reader.readLine()) != null) {
                        buffer.append(line);
                    }
                    String finalJson = buffer.toString();
                    JSONObject parentObject = new JSONObject(finalJson);
                    JSONArray parentArray = parentObject.getJSONArray("data");
                    for (int i = 0; i < parentArray.length(); i++) {
                        Jobs item = new Gson().fromJson(parentArray.get(i).toString(), Jobs.class);
                        list.add(item);
                    }
                } else {
                    response = connection.getResponseMessage();
                }

            } catch (MalformedURLException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } catch (JSONException e) {
                e.printStackTrace();
            } finally {
                if (connection != null)
                    connection.disconnect();
                try {
                    if (reader != null)
                        reader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                nextStep();
            }
        }
    });
    t.start();
    return list;
}

public Boolean sendJobs(final List<Jobs> job, final String... params) {
    final Boolean[] result = {false};
    Thread t = new Thread(new Runnable() {

        @Override
        public void run() {
            URL url = null;
            HttpURLConnection conn = null;
            try {
                url = new URL(params[0]);
                conn = (HttpURLConnection) url.openConnection();
                conn.setRequestMethod("POST");
                conn.setRequestProperty("Content-Type", "application/json");
                conn.setDoInput(true);
                conn.setDoOutput(true);
                String str = new Gson().toJson(job);
                Log.d(TAG, str);
                byte[] outputInBytes = str.getBytes();
                OutputStream os = conn.getOutputStream();
                os.write(outputInBytes);
                os.flush();

                int responseCode = conn.getResponseCode();
                String response = null;
                if (responseCode == HttpsURLConnection.HTTP_OK) {
                    String line;
                    BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
                    while ((line = br.readLine()) != null) {
                        response += line;
                    }
                    result[0] = true;
                } else {
                    response = conn.getResponseMessage();
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                conn.disconnect();
                nextStep();
            }
        }
    });
    t.start();
    return result[0];
}
}

Всякий раз, когда поток заканчивается, он вызывает метод nextStep (), который запускает следующий заголовок.

0 голосов
/ 20 марта 2019

Мне нужно вызвать поток, дождаться ответа и вызвать другой поток. Их ответы я должен использовать их в деятельности

Пример использования асинхронных задач для достижения цели.

В этом коде позвольте A быть вашей деятельностью, которая должна вызывать поток, дождитесь ответа и позвоните в другую ветку. Настройте по мере необходимости.

Поскольку вы никогда не ждете в потоках пользовательского интерфейса, для выполнения синхронизации используются обратные вызовы.

Пусть A будет вашим классом активности: 

    public class A extends Activity {

       // some method in activity where you launch a background thread (B)
       // which then completes and invokes callback which then creates and launches
       // a background thread (C) which then completes and invokes a callback.
       //
       // In callback C, you are on the UI thread.
       protected void someMethod() {

          new B(new B.CallbackB() { 
             public void result(Object o) {
                new C(new C.CallbackC() {
                   public void result(Object o, Object answerFromB) {
                      // OK - C is now done and we are on UI thread!
                      //   'o' is answer from C
                      //   'answerFromB' also provided
                   }
                }, o).execute(new Object());
             }
          ).execute(new Object());
       }

    }

Определить класс B: 

    public class B extends AsyncTask<Object, Void, Object> {

       public static interface CallbackB {
          void result(Object o);
       }

       private CallbackB cb;

       public B (CallbackB cb) {
          this.cb = cb;
       }

       protected Object doInBackground(Object... params) {
          // do work and return an answer.
          return new Object();
       }

       protected void onPostExecute(Object result) {
          if (cb != null) {
             cb.result(result);
          }
       }

    }

Определить класс C: 

    public class C extends AsyncTask<Object, Void, Object> {

       public static interface CallbackC {
          void result(Object o, Object answerFromB);
       }

       private CallbackC cb;
       private Object answerFromB;

       public C (CallbackC cb, Object answerFromB) {
          this.cb = cb;
          this.answerFromB = answerFromB;
       }

       protected Object doInBackground(Object... params) {
          // do work and return an answer.
          return new Object();
       }

       protected void onPostExecute(Object result) {
          if (cb != null) {
             cb.result(result, answerFromB);
          }
       }

    }

Для справки: https://stackoverflow.com/a/9963705/2711811

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.

Похожие темы

...