后台任务在前一个任务之前执行（如何防止）

Question

我在后台发送电子邮件时遇到问题。我试图将文本集作为电子邮件放入 EditText 中，但我的邮箱总是有 null，因为在我在 EditText 中输入任何内容之前总是调用 AsyncTask，然后在对话框中按“确定”。

final int partsCount = imageKeeperList.size();

                        class PhotoSend extends AsyncTask <Void, Void, Void>{

                            @Override
                            protected void onPreExecute() {


                            }


                            @Override
                            protected Void doInBackground(Void... voids) {

                                final String username = "sampleemail@gmail.com";
                                final String password = "somepassword";

                                Properties props = new Properties();
                                props.put("mail.smtp.host", "smtp.gmail.com");
                                props.put("mail.smtp.socketFactory.port", "465");
                                props.put("mail.smtp.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
                                props.put("mail.smtp.auth", "true");
                                props.put("mail.smtp.port", "465");

                                Session session = Session.getDefaultInstance(props,

                                        new javax.mail.Authenticator() {

                                            protected PasswordAuthentication getPasswordAuthentication() {
                                                return new PasswordAuthentication(username,password);

                                            }
                                        });

                                try {

                                    Message message = new MimeMessage(session);
                                    message.setFrom(new InternetAddress("sampleemail@gmail.com"));
                                    message.setRecipients(Message.RecipientType.TO, InternetAddress.parse("targetemail@gmail.pl"));
                                    message.setSubject("Subject of email");
                                    message.setText("Some text.");
                                    Transport.send(message);
                                    Log.d(TAG, "onInput: background");

                                } catch (MessagingException e) {

                                    throw new RuntimeException(e);

                                }
                                return null;
                            }

                            @Override
                            protected void onPostExecute(Void aVoid) {
                                Toast.makeText(getContext(), "Sent.", Toast.LENGTH_SHORT).show();
                                Log.d(TAG, "onInput: postExecute");
                            }
                        }

                        new MaterialDialog.Builder(getContext())

                                .content("Set description")
                                .inputType(InputType.TYPE_TEXT_FLAG_IME_MULTI_LINE)
                                .input("short description", "", new MaterialDialog.InputCallback() {
                                    @Override
                                    public void onInput(MaterialDialog dialog, CharSequence input) {

                                        if (input.length() == 0) partPicturesDescription = "No description";
                                        else partPicturesDescription = dialog.getInputEditText().getText().toString();
                                        dialog.dismiss();
                                        Log.d(TAG, "onInput: preExecute");
                                    }
                                }).show();

                        PhotoSend ps = new PhotoSend();
                        ps.execute(partPicturesDescription);
                    } 

我的 onPreExecute() 方法中有对话框，但它保持不变，doInBackground 优先。

Answer 1

看看我能不能帮到你。所以首先你对 asyncTasks 有一点误用。

AsyncTask 旨在执行一个简短的“后台”操作，将结果返回给 UI 线程。 UI 线程是唯一可以触摸 UI 元素而不会发生冲突或正常崩溃的线程。

所以典型的行为是

UI-Thread -> 获取用户输入

AsyncTask (Background Thread) -> 发送或处理传入的数据

UI-Thread -> 通知用户成功/失败

所以你有几个选择。

1) 在启动 AsyncTask 之前执行 UI 对话框

    private void getUserInput(){
         Session session = Session.getDefaultInstance(props,
                              new javax.mail.Authenticator() {
                                  protected PasswordAuthentication getPasswordAuthentication() {
                                      doBackgroundProcessing(new PasswordAuthentication(username,password));

                                 }
                             });
      }

private void doBackgroundProcessing(PasswordAuthentication passAuth){
    if(passAuth == null || !passAuth.isSuccessful()){ //or whatever success flag they have
        Log.e(TAG, "Failed to get credential token");
        return;
    }

    //else we send it to the server it appears based on your code\
    showBusyIndicator() //IF you need to block the UI from interacting while you send, NOTE* showBusyIndicator is just a method YOU would create to show one.
    new PhotoSend()() {
        @Override
        public void onPostTask(Boolean wasSuccessful) {
             //I recommend actually returning a valid result rather then Void so you know whether or not it succeeded.
             if(wasSuccessful){
                 //close busy indicator, and notify of success
             }else{
                 //close busy indicator, and notify of error
             }
        }
    }
}

您的另一个选择是迁移到协程。这些非常方便，因为您可以使用 async 和 await 来暂停您的操作。

这是一个在继续前进之前等待对话框返回名称的示例。

protected suspend fun getNameFromDialog(): String? = suspendCancellableCoroutine { c ->
    A35Log.v(mClassTag, "getNameFromDialog")
    GetTextEntryDialog.newInstance(getParamsForTextDialog(), object : ITextEntryDialogListener {
        override fun onTextEntered(text: String) {
            if(!c.isCompleted) {
                A35Log.v(mClassTag, "User entered name: $text")
                c.resume(text)
            }
        }
        override fun onCancel(){
            if(!c.isCompleted) {
                A35Log.v(mClassTag, "User canceled name entry")
                c.resume(null)
            }
        }
    }).show(supportFragmentManager, mClassTag)
}

此示例的用例只是获取名称，然后保存到数据库。它看起来像这样：

  private fun saveAsDuplicateConfiguration(){
    launch(UI){
        setIsActionInProgress(true)
        val configName = withContext(DefaultDispatcher) { getNameFromDialog() }
        if(configName == null){
            showFancyToast(getString(R.string.canceled), true, FancyToast.INFO)
        }else{
            withContext(DefaultDispatcher){
                try{
                    withTimeout(TIMEOUT_FOR_DB_INTERACTION_MS){
                        A35Log.v(mClassTag, "inserting copy of config with name :$configName")
                        val configCopy = DeviceAndConfigurationHelper.getCopyOfConfigurationModel(mSelectedConfiguration!!)
                        configCopy.setConfigName(configName)
                        configCopy.setDeviceType(FeatureHelper.PRO_DEVICE_KEY) //todo should come from BLE eventually
                        if(SSDBHelper.insertConfiguration(configCopy) > 0){
                            showFancyToast(getString(R.string.successfully_saved), true, FancyToast.SUCCESS)
                            finishCurrentActivity(SSGlobals.TimeOuts.TOAST_DISPLAY_DELAY_CLOSE_MS, true)
                        }else{
                            showFancyToast(getString(R.string.error_saving_copy))
                        }
                    }
                }catch (e: TimeoutCancellationException) {
                    showFancyToast(getString(R.string.error_timed_out) + ", " + getString(R.string.error_please_try_again_or_press_back), true, FancyToast.ERROR, "TimedOut with error: ${e.message}")
                }catch(ex: JobCancellationException){
                    showFancyToast(getString(R.string.canceled))
                }catch(ex: Exception){
                    showFancyToast(getString(R.string.error_saving_copy) + ", " + getString(R.string.error_please_try_again_or_press_back), true, FancyToast.ERROR, "Error deleting: ${ex.message}")
                }finally {
                    setIsActionInProgress(false)
                }
            }
        }
    }
}

如您所见，GetNameFromDialog 是一个阻塞和等待方法，因此 saveAsDuplicateConfiguration 直到完成获取名称后才会继续，然后它会尝试使用它。

这个故事的寓意是协程非常棒，并且允许干净的异步代码，但学习曲线很陡峭。所以做你觉得舒服的事，但是“我不能强调这一点”。不要尝试从 AsyncTask 内部进行对话框和 UI 检索，这将要求内存泄漏、生命周期问题和糟糕的代码管理。

您真的可以通过尝试传入一个侦听器并将处理放入您的 asynctask 中会话身份验证器的对话回调中来使其变得糟糕，但这可能会失败，因为垃圾收集可以在退出执行方法时获取该对象，所以这将是一个非常糟糕的主意。

希望对你有帮助，有问题可以问。

快乐编码。