并行产生来自多个来源的数据

Question

我有一种情况，我想从多个来源异步传输相同类型的数据。数据结果应该在输入时输出。最简单的方法是什么？ yield return 被阻塞了，所以这不是我想要的。在下面的示例中，我希望源 B 的数据在源 A 的数据之前输出。

List<string> GetComputerRecordsFromA(int computerId)
{
    Thread.sleep(100);
    return new List<Record> {"Record1","Record2","Record3"};
}

List<int> GetComputerRecordsFromB()
{
    return new List<int> {"Record1","Record2","Record3"};
}

IEnumerable<List<int>> GetDataBlocks()
{
    //How to yield out in the order data comes available?? 
    var computerIds = new List<int> {1,3,99,4};
    foreach(int id in computerIds)
    {
        yield return GetDataFromA();
        yield return GetDataFromB();
    }
}

Answer 1

您可以同时执行操作 - 使用 BlockingCollection 和几个线程。每个输入一个线程和一个 - 可能是您的主线程 - 从列表中产生返回项目。

请注意，您可能无法到达列表末尾 - 如果您的阅读器比您的编写器快，即使编写器稍后会向列表写入更多数据，它也会认为它已到达列表末尾。