Использование synchronized () в android - PullRequest
Новая
       87

Использование synchronized () в android

0 голосов
/ 07 августа 2020

У меня есть проект android, и я использую wait () и notify (), поэтому определенный код выполняется только после фоновой задачи, это функция, которая вызывает firebase: 

//Code Snippet 1
 public  Task<String> checkIfJokeSavedFirebase() throws InterruptedException {
        final String[] idToken = {""};
        Map<String, Object> data = new HashMap<>();
        FirebaseUser mUser = FirebaseAuth.getInstance().getCurrentUser();
        mUser.getIdToken(true)
                .addOnCompleteListener(new OnCompleteListener<GetTokenResult>() {
                    public void onComplete(@NonNull Task<GetTokenResult> task) {
                        if (task.isSuccessful()) {
                            idToken[0] = task.getResult().getToken();
                            data.put("token", idToken[0]);
                            String someObject = "test";
                            synchronized (someObject) {
                                Log.d("longdebug","someObject pre notify");
                                someObject.notify();
                            }
                            //notify();
                            // Send token to your backend via HTTPS
                            // ...
                        } else {
                            // Handle error -> task.getException();
                        }
                    }
                });
        String someObject = "test";
        synchronized (someObject){
            Log.d("longdebug","someObject pre wait");
            someObject.wait();
        }
        Log.d("runtimeexception","pre actually called");
        data.put("token", idToken[0]);
        //data.put("jokeid",jokeJSON.getString("id"));
        return FirebaseFunctions.getInstance()
                .getHttpsCallable("checkIfJokeSaved")
                .call(data)
                .continueWith(new Continuation<HttpsCallableResult, String>() {
                    @Override
                    public String then(@NonNull Task<HttpsCallableResult> task) throws Exception {
                        Log.d("runtimeexception",".then");
                        HashMap result = (HashMap) task.getResult().getData();
                        JSONObject res = new JSONObject(result);
                        String jokeStored = res.getString("jokeStored");
                        Log.d("runtimeexception","jokeStored returned");
                        return jokeStored;
                    }
                });
    }

И мой код, который вызывает функцию :: 

//Code Snippet 2
 try {
      Log.d("runtimeexception","pre checkSavedCall");
      activity.checkIfJokeSavedFirebase().addOnCompleteListener(new OnCompleteListener<String>() {
                    @Override
                    public void onComplete(@NonNull Task<String> task) {
                        Log.d("runtimeexception","pre task.getResult");
                        Log.d("runtimeexception","task.getResult:" + task.getResult());
                        jokeSaved = Boolean.parseBoolean(task.getResult());
                        String synchronizedChannel = "displaysaved";
                        synchronized (synchronizedChannel){
                            Log.d("runtimeexception","pre notify");
                            synchronizedChannel.notifyAll();
                        }
                    }
                });
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            String synchronizedChannel = "displaysaved";
            synchronized (synchronizedChannel){
                try {
                    Log.d("runtimeexception","pre wait");
                    synchronizedChannel.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

Мой код не попадает в «.then» во фрагменте кода 1, но когда я удаляю: 

synchronized (synchronizedChannel){
                try {
                    Log.d("runtimeexception","pre wait");
                    synchronizedChannel.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

из фрагмента 2 фрагмент 1 попадает в журнал «.then» и завершает выполнение. Как возможно, что удаление оператора wait () приведет к завершению вызова функции firebase?

1 Ответ

1 голос
/ 12 августа 2020

Я не нашел решения проблемы Synchronized, но я просто переключился с AsyncTask на Rx Java и переместил вызовы Firebase в Task, что позволило мне избавиться от всех предыдущих синхронизированных операторов, и требовалось только два синхронизированных оператора в Задаче.

...