MongoDB 中的异步更改流

Question

我想在不阻塞线程的情况下侦听集合的更改流。在下面的代码中，ForEachAsync 将永远阻塞，并在更改发生时对其进行处理。using (var cursor = await collection.WatchAsync()){    await cursor.ForEachAsync(change =>    {        // process change event    });}我已尝试删除“await”并将任务存储在变量中，但是在我实际等待或之前不会处理任何更改。稍后等待（） 任务。我希望即使我不等待任务，事件仍然会被处理。我该怎么办，这样我的整个程序就不会阻止侦听更改？我正在考虑将功能包装在新线程中，但这真的有必要吗？

Answer 1

我没有足够的声誉来评论（还），所以我以答案的形式提供反馈：

在这种情况下，您应该使用事件（侦听器，处理程序），而不是等待/异步。如果没有更多关于你想要完成什么的信息，就很难详细说明这一点。

Answer 2

所以，我发现以下工作...

static void Main(string[] args)

{

    Task watchTask = WatchCollection();

    // Do other stuff here, while watching...

}

private static async Task WatchCollection()

{

    using (var cursor = collection.Watch())

    {

        await cursor.ForEachAsync(change =>

        {

            // process change event

        });

    }

}

当我试图这样做时，这不起作用：

static void Main(string[] args)

{

    using (var cursor = collection.Watch())

    {

        Task watchTask cursor.ForEachAsync(change =>

        {

            // process change event

        });

    }

    // Do other stuff here, while watching

}

因此，实际的 ForEachAsync 任务被等待，而包装整个功能的外部任务则未等待...我要么太累了，要么对任务不够熟悉，无法很好地解释为什么一个有效而另一个不起作用。