Создание нескольких процессов одновременно с ошибкой обработчика - PullRequest
Новая
       21

Создание нескольких процессов одновременно с ошибкой обработчика

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

Я создаю приложение, которое может запускать 2 процесса одновременно (сохранение в базу данных / отправка в API), но я столкнулся с проблемой из-за моего шага. Это мой код при работе с потоками:

этомой код: 

public void timerToSaveSend() {
    Thread t1 = new Thread() {
        @Override
        public void run() {
            saving();

        }
    };
    t1.start();
    Thread t2 = new Thread(){
        @Override
        public void run() {
            sending();
        }
    };
    t2.start();
}


    private void sending() {
    //dataSendApi
    handler10 = new Handler();
    handler10.postDelayed(new Runnable() {
        @Override
        public void run() {
            try {
                Retrofit.Builder builder = new Retrofit.Builder()
                        .baseUrl("http://" + ADDRESS + ":" + PORT)
                        .addConverterFactory(GsonConverterFactory.create());

                Retrofit retrofit = builder.build();
                API locate = retrofit.create(API.class);

                Call<MapDetails> call = locate.mapDetailLocation(data);
                call.enqueue(new Callback<MapDetails>() {
                    @Override
                    public void onResponse(Call<MapDetails> call, 
                    Response<MapDetails> response) {
                        String portString = String.valueOf(portss);

                    }

                    @Override
                    public void onFailure(Call call, Throwable t) {
                        Log.d("Message: ", "Data not sent, please check your 
                        network connection.");

                    }

                });
            } catch (Exception e) {
                Toast.makeText(NavDrawerFleet.this, "Disconnected from Internet, Please Configure Settings", Toast.LENGTH_SHORT).show();
                restFailed();
            }


        }
    }, 10000);


}

private void saving() {
    //4SECOND
    handler2 = new Handler();
    handler2.postDelayed(new Runnable() {
        @Override
        public void run() {
            DatabaseHelper databaseHelper = new DatabaseHelper(getApplicationContext());
            SQLiteDatabase db = databaseHelper.getWritableDatabase();
            well2 = String.valueOf(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss", java.util.Locale.getDefault()).format(new java.util.Date()));
            boolean accepted = databaseHelper.saveLocationToLocalDatabase(gg, hidelat.getText().toString(), hidelon.getText().toString(), well2, "1", "9090", db);
            failedCount.setText(String.valueOf(retryList.size()));
            lat2 = hidelat.getText().toString();
            lon2 = hidelon.getText().toString();
            MapDetails mapDetails = new MapDetails(gg, hidelat.getText().toString(), hidelon.getText().toString(), well2, "1", 9090);
            data.add(mapDetails);
            retry2 = new NotSentModuleGetterSetter(hidelat.getText().toString(), hidelon.getText().toString(), well2);
            retryList.add(retry2);
            retrylist_adapter.notifyDataSetChanged();
            if (accepted == true)
                Log.w("Data Entered: ", "1st Copy");

        }
    }, 2000);
    saving();
        }

и это моя ошибка:

enter image description here

PS.Мне было интересно, что мой код полностью не работает, хотя я хочу и другую возможную реализацию кода с этим, например, asynctask для работы с этим множественным процессом + с многопоточностью в одном проходе.

1 Ответ

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

Для многопоточности, пожалуйста, подумайте об использовании RxJava.Это было бы так просто: 

Observable.fromCallable(new Callable<Object>() {
      @Override public Object call() throws Exception {
        saving();
        return null;
      }
    })
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<Object>() {
        @Override public void onSubscribe(Disposable d) {

        }

        @Override public void onNext(Object o) {

        }

        @Override public void onError(Throwable e) {

        }

        @Override public void onComplete() {

        }
    });

Проверьте эту ссылку, чтобы узнать, как интегрировать RxJava в ваш проект https://github.com/ReactiveX/RxAndroid

...