我如何等到加载来自首选项数据存储的数据？

Question

我正在尝试制作LibGDX实时墙纸。但是我认为这与我目前遇到的问题无关。基本上，我将墙纸的设置存储在首选项数据存储中。现在，如果您需要从数据存储中检索数据，则需要检索kotlin flow并使用它来获取首选项。在libgdx的applicationListener increate（）方法中，我需要创建一个ktxscreen对象。我决定将所有偏好传递在我的屏幕的构造函数中。但是，由于flow的数据只能在coroutine中获得我的流排放值。我用非常脏的解决了此问题，而（userPreferences == null）ume一件代码，基本上会阻止整个应用程序，直到发出偏好，以便我可以构造我的ktxscreen> 。解决这个问题的好方法是什么？

Answer 1

在libgdx中可以接受以阻止渲染线程。这是与Android主线程的单独线程，因此它不会冻结Android UI，也不会使您有ANR的风险（应用程序不响应错误）。它会在阻塞时冻结任何游戏/壁纸渲染，但是当您仍在加载场景时，这还可以。

因此，在中使用runblocking create（create（）或render（）等待第一批设置。由于KTXSCREEN不使用create（），因此您可以在属性初始化中直接阻止。您可以在流程上调用first（）从中获得一个项目，这对于您的KTXSCREEN类的初始设置就可以了。

如果您使用的是libktx的ktx-async库，则可以在渲染线程上收集流程，因此，如果用户在运行壁纸时将用户更新设置，则将安全地更新您的设置。

这是您如何实现这一目标的一个例子（我没有测试），但是可以处理许多可接受的不同方式。注意：这是假设您在渲染线程上实例化此屏幕，而不是Android主线程。渲染线程是用于调用create（）的渲染线程，这是实例化第一个屏幕的典型场所。

class MyScreen(
    val settingsFlow: Flow<UserPreferences>
): KtxScreen {

    var prefs: UserPreferences = runBlocking { settingsFlow.first() }

    init {
        settingsFlow
            .drop(1) // the first one should be the value we already got above
                     // unless the user changed them impossibly fast
            .onEach { prefs = it }
            .launchIn(KtxAsync)
    }

    //...
}

如果您想在墙纸中显示某种初始加载图像，则可以在dender函数中使用此类功能。但是我认为这不必是必要的，因为偏好可能会花费不到半秒钟的加载。

class MyScreen(
    val settingsFlow: Flow<UserPreferences>
): KtxScreen {

    var _prefs: UserPreferences? = null

    init {
        settingsFlow
            .onEach { _prefs = it }
            .launchIn(KtxAsync)
    }

    override fun render() {
        val prefs = _prefs // for the sake of smart-casting
        if (prefs == null) {
            renderLoadingImage()
        } else {
            renderScene(prefs)
        }
    }

    //...

    private fun renderScene(prefs: UserPreferences) {
        //...
    }
}

Answer 2

如果我们需要从数据存储中获取键值作为同步方式，那么我们需要使用Runblocking阻止线程，以便将数据返回原始数据类型中的数据。

fun getValue(context: Context): Int {

    return runBlocking(Dispatchers.IO) {
    context.dataStore.dataStore.data.first()[EXAMPLE_COUNTER] ?: 0

}}

INCASE以异步方式从数据存储中获取值，然后直接调用将返回流的方法。

fun <T> DataStore<Preferences>.getValueFlow(
key: Preferences.Key<T>,
defaultValue: T ): Flow<T> {
return this.data
    .catch { exception ->
        if (exception is IOException) {
            emit(emptyPreferences())
        } else {
            throw exception
        }}.map { preferences ->
        preferences[key] ?: defaultValue
    }}