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

Question

我有一种情况，我想从多个来源异步流式传输相同类型的数据。数据结果应该在他们进入时出现。最简单的方法是什么？产量回报受阻，所以这不是我想要的。在下面的例子中，我想从源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和线程数。每个输入和一个线程的一个线程 - 您的主线程可能 - yield-返回列表中的项目。

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