如何创建基于任务/TPL 的工作队列/事件循环？

Question

我有一个系统，其中所有数据库操作 (SQLite) 必须通过使用工作处理器来运行，因此我可以随意安排它们。

现在处理器有一个Task<TResult> PostAsync<TResult>(Func<SQLiteConnection, TResult> dbFunc)，但我能想出的唯一理智的实现是一个基于堆栈的 UI 线程工作循环，它利用Task 能够将结果推迟到处理实际操作的那一刻。

它工作正常，但它用 SQLite 调用阻塞了 UI 线程。我宁愿不发生这种情况，但我能想出的唯一想法是产生一个工作线程来刷新队列或为每个操作提供它自己的工作线程。我认为这两种方法都不是最明智的方法，因为它们最终会在每次需要访问数据库时创建线程。

如何实现堆栈中的dbFunc 参数在后台线程中执行但所述线程只创建一次或尽可能轻量级的实现？

这必须在 Xamarin 环境中工作。在 PCL 或 Android+iOS 实现中。

Answer 1

您不需要泵或队列类型的解决方案来完成此操作。只需通过SemaphoreSlim 序列化对SQLiteConnection 的访问即可解决问题（当然，您需要单例SQLiteConnection 和SemaphoreSlim 实例）：

private readonly SQLiteConnection _sharedConnection;
private readonly SemaphoreSlim Semaphore = new SemaphoreSlim(1, 1);

public async Task<TResult> PostAsync<TResult>(Func<SQLiteConnection, TResult> dbFunc, CancellationToken ct)
{
    TResult result;
    bool needToRelease = false;

    try
    {
        await Semaphore.WaitAsync(ct).ConfigureAwait(false);

        // If we got this far, Release *must* be called.
        needToRelease = true;

        ct.ThrowIfCancellationRequested();

        // Push the work off to the thread pool in the event that
        // WaitAsync completed synchronously and we're still on the UI thread.
        result = await Task
            .Run(() => dbFunc(_sharedConnection), ct)
            .ConfigureAwait(false);
    }
    finally
    {
        if (needToRelease) {
            Semaphore.Release();
        }
    }

    return result;
}

以上内容适用于 Xamarin.iOS 和 Xamarin.Android - 但是我知道 SemaphoreSlim 在某些 PCL 配置文件中不可用。

您可能认为每次需要访问数据库时都启动多个 Task 实例有点丰富，但实际上它并没有太多工作，即使对于移动设备也是如此。

上面的一个更大的问题是它仍然是“假”的异步。我们只是在滥用Task.Run 将阻塞操作卸载到线程池。

因此，值得一提的是更基本的替代方案（I myself use）。它是通过包装类公开您的SQLiteConnection，其中每个公共方法locks 在共享对象上执行SQLiteConnection 实例上的相关方法之前。在这种情况下，调用者是想直接执行潜在的阻塞调用，还是通过Task.Run 将它们推到线程池中，这取决于调用者。在SQLite.Net 开始提供true异步之前，我相信这是使用SQLiteConnection 管理并发的最佳方法。