有没有办法处理任何类型的集合，而不是仅仅依赖 Array、List 等？

Question

这个例子是一个名为“WriteLines”的方法，它接受一个字符串数组并将它们添加到异步文件写入器。它有效，但我很好奇是否有一种有趣的方式来支持 -any- 字符串集合，而不是依赖程序员转换为数组。

我想出了类似的东西：

public void AddLines(IEnumerable<string> lines)
{
    // grab the queue
    lock (_queue)
    {
        // loop through the collection and enqueue each line
        for (int i = 0, count = lines.Count(); i < count; i++)
        {
            _queue.Enqueue(lines.ElementAt(i));
        }
    }
    // notify the thread it has work to do.
    _hasNewItems.Set();
}

这似乎可行，但我不知道它有任何性能影响，或任何逻辑影响（订单会发生什么？我认为这将允许无序集合工作，例如HashSet）。

有没有更被接受的方法来实现这一点？

Answer 1

您已收到IEnumerable<string> - 这意味着您可以对其进行迭代。哎呀，甚至还有一个语言功能专门 - foreach：

foreach (string line in lines)
{
    _queue.Enqueue(line);
}

与您现有的方法不同，这只会对序列进行一次迭代。您当前的代码将根据底层实现的不同表现 - 在某些情况下 Count() 和 ElementAt 已优化，但在某些情况下它们不是。如果您使用迭代器块并记录日志，您可以很容易地看到这一点：

public IEnumerable<string> GetItems()
{
    Console.WriteLine("yielding a");
    yield return "a";
    Console.WriteLine("yielding b");
    yield return "b";
    Console.WriteLine("yielding c");
    yield return "c";
}

尝试使用您当前的实现调用AddLines(GetItems())，然后查看控制台...

Answer 2

由于您使用的是线程，因此也添加此答案，请改用ConcurrentQueue，如下所示：

// the provider method
// _queue = new BlockingCollection<string>()
public void AddLines(IEnumerable<string> lines)
{
   foreach (var line in lines)
   {
     _queue.Add(line);
   }
}

不需要锁，并且允许多个消费者和提供者，因为我们为每个添加的元素进行标记。

消费者基本上只需要var workitem = _queue.Take();