如何使用异步任务侦听器返回并暂停Coroutine？

Question

我要做的是以下内容：

1. 使用调色板从API加载代理图标
2. ，确定什么是充满活力的Swatch
3. 设置此背景RGB颜色，然后将其保存到数据库
4. 数据库中，将更新，更新流程并推动新的流程UI
5. UI的更新会选择它，然后将其设置为回收器视图，

但是，我正在努力使其在我的存储库中工作。我的功能看起来像这样：

suspend fun updateAgentBackground(agent: Agent, successResult: SuccessResult) {
    if (agent.backgroundRgb == null) {
        withContext(Dispatchers.IO) {
            Palette.Builder(successResult.drawable.toBitmap()).generate { palette ->
                val rgb = palette?.vibrantSwatch?.rgb
                if (rgb != null) {
                    val agentWithBackground = agent.copy(backgroundRgb = rgb)
                    agentDao.insertAgent(agentWithBackground.toAgentEntity())
                }
            }
        }
    }
}

但是，它在 agentdao.intertagent（）上在运行时崩溃，因为它说它在主线程上运行了DB操作。我也无法将此方法包裹在 generate（）带有 withContext（dispatchers.io）的回调中，因为它不在coroutine主体中。

这就是 palette.builder（）。generate（）函数在源代码中的样子：

@NonNull
public AsyncTask<Bitmap, Void, Palette> generate(
        @NonNull final PaletteAsyncListener listener) {
    if (listener == null) {
        throw new IllegalArgumentException("listener can not be null");
    }

    return new AsyncTask<Bitmap, Void, Palette>() {
        @Override
        @Nullable
        protected Palette doInBackground(Bitmap... params) {
            try {
                return generate();
            } catch (Exception e) {
                Log.e(LOG_TAG, "Exception thrown during async generate", e);
                return null;
            }
        }

        @Override
        protected void onPostExecute(@Nullable Palette colorExtractor) {
            listener.onGenerated(colorExtractor);
        }
    }.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, mBitmap);
}

public interface PaletteAsyncListener {
    void onGenerated(@Nullable Palette palette);
}

因此，我将其传递给它 paletteasynclistener ，它 hurn hurn oster > ongererated（）。我以某种方式希望这种方法暂停Coroutine，并以更新的背景返回 Agent 。或以某种方式能够在此回调中调用我的DB方法 AgentDao.Intertagent（）在主线程中。

我可以以某种方式混合并匹配源代码如何使用 asynctask 与我的coroutines使用？

Answer 1

asynctask 在API级别30中弃用，请考虑使用Kotlin Coroutines或其他 Kotlin并发实用程序。如果没有 asynctask 它将看起来像这样的东西：

在 palette.builder class：

suspend fun generatePalette() = withContext(Dispatchers.IO) {
    generate()
}

in储存库中：

suspend fun updateAgentBackground(agent: Agent, successResult: SuccessResult) {
    if (agent.backgroundRgb == null) {
        val palette = Palette.Builder(successResult.drawable.toBitmap()).generatePalette()
        val rgb = palette?.vibrantSwatch?.rgb
        if (rgb != null) {
            val agentWithBackground = agent.copy(backgroundRgb = rgb)
            agentDao.insertAgent(agentWithBackground.toAgentEntity())
        }
    }
}

也在 agentdao 标记函数 insertagent insertagent < /code> as <代码>暂停：

suspend fun insertAgent(...)

Answer 2

如果由于某种原因无法修改调色板的源代码。Builder类，则可以编写这样的暂停适应功能。 sustendCancellableCoroutine 是通过暂停Coroutine并为您直接使用暂停的延续来将基于回调的功能转换为悬挂功能。回调发射时恢复Coroutine，并在恢复之前取消Coroutine，取消工作。

suspend fun Palette.Builder.await(): Palette? = suspendCancellableCoroutine { cont ->
    val task = generate { cont.resume(it) }
    cont.invokeOnCancellation(task.cancel())
}

然后，您的其他函数可以同步写入，并在必要时使用 withContext ：

suspend fun updateAgentBackground(agent: Agent, successResult: SuccessResult) {
    if (agent.backgroundRgb == null) {
        val palette = Palette.Builder(successResult.drawable.toBitmap()).await()
        val rgb = palette?.vibrantSwatch?.rgb
        if (rgb != null) {
            val agentWithBackground = agent.copy(backgroundRgb = rgb)
            agentDao.insertAgent(agentWithBackground.toAgentEntity())
        }
    }
}

确保您将标记 AgentDao.InterTagent（）将其标记为 suppend 功能，因此您可以在Coroutine中的任何地方致电，而不必担心呼叫线程。

上面的代码假定 tobitmap（）是非障碍物。如果阻止它，则应用context（）将其包裹在适当的中。