如何重新启动函数，当它操作的数据更新时

Question

在片段的onCreateView() 方法中，我将3 个valueEventListeners 附加到firebase 数据库中不同的、互斥的位置。每当引用处的数据更新时，它们都会异步触发。我的示例代码如下所示：

override fun onCreateView(inflater: LayoutInflater, container: ViewGroup?, savedInstanceState: Bundle?): View? {
    listner1 = ref1.addCustomValueEventListener {
        list1.clear()
        // do some operation and populate list1
        rewriteMainData()
    }
    listner2 = ref2.addCustomValueEventListener {
        list2.clear()
        // do some operation and populate list2
        rewriteMainData()
    }
    listner3 = ref3.addCustomValueEventListener {
        list3.clear()
        // do some operation and populate list3
        rewriteMainData()
    }
}

private fun rewriteMainData() {
    mainList.clear()
    mainDbReference.addCustomListenerForSingleValueEvent {
        // compare the values present here with values in list1, list2, list3
        // populate mainList with appropriate values
        // notifyAdapterDataSetChanged
    }
    return
}

// EXTENSION FUNCTION
internal inline fun DatabaseReference.addCustomValueEventListener(crossinline onDataChange: (DataSnapshot) -> Unit) =
addValueEventListener(object : ValueEventListener {
    override fun onDataChange(snapshot: DataSnapshot) {
        onDataChange(snapshot)
    }
    override fun onCancelled(error: DatabaseError) {
        Log.e(TAG, "onCancelled: ", error.toException())
    }
})

然而，在这个例子中，如果一个监听器紧接着另一个被触发，那么rewriteMainData() 将被调用两次。届时，mainList 将被两个回调同时写入。解决此问题的一种方法是使用ReentrantLock 的实例来避免同时写入。但这使得最新的调用要等到之前的调用完成，这是多余的，因为所有数据都将被清除和重写。
因此，有什么方法可以知道何时调用 rewriteMainData() 以及它是否已经在运行，那么只需中止并使用更新的列表重新启动函数？

Answer 1

您可以yield，每次在做任何密集工作之前检查当前协程的取消。

// instance variable on the class
var job1: Job? = null

override fun onCreateView(inflater: LayoutInflater, container: ViewGroup?, savedInstanceState: Bundle?): View? {
    ref1.addCustomValueEventListener {
        job1?.cancel()
        job2?.cancel()
        job3?.cancel()

        job1 = lifecycleScope.launch(Dispatchers.Default) {
            list1.clear()
    
            // do some operation and populate list1
            rewriteMainData()
        }
    }
    // ...
}


private suspend fun rewriteMainData() {
    mainList.clear()

    // before every intensive work, to check for cancellation.
    yield()
    // some work involving cpu consumption or takes significant time.
}

请注意，如果工作只是同步更新列表，则影响很小甚至更糟，这仅涉及几个 CPU 周期和毫秒的时间。仅当您确定 rewriteMainData 在您当前的代码中所做的工作会影响性能时才使用此选项。

Answer 2

mainList 将被两个回调同时写入。

使用您这里的代码是不可能的。数据库回调默认在 Android 主线程上调用，这意味着它们不能同时被调用。它们将被顺序调用。因此，您不必担心线程或锁定。