android - 在android中使用同步（）

Question

我有一个 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();
                }
            }

我的代码没有进入代码片段 1 中的“.then”登录，但是当我删除时：

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

从片段 2 开始，片段 1 进入“.then”日志并完成执行。删除 wait() 语句怎么可能导致对 firebase 函数的调用完成？

标签： androidfirebasegoogle-cloud-firestore

Answer 1

我没有找到 Synchronized 问题的解决方案，但我只是从 AsyncTask 切换到 RxJava，并将 Firebase 调用移动到一个 Task，这样我就可以摆脱所有以前的同步语句，并且只需要两个同步语句在任务中。