c# - 在特定时间戳创建 ConcurrentQueue 中所有现有项目列表的最有效方法

Question

我必须维护信息日志，这些日志可以同时从多个线程写入，但是当我需要它们时，我只使用一个线程将其出列，在出列集合之间需要大约 5 秒的时间。

以下是我编写的用于将其出队的代码。

if (timeNotReached)
{
   InformationLogQueue.Enqueue(informationLog);
}
else
{
    int currentLogCount = InformationLogQueue.Count;
            var informationLogs = new List<InformationLog>();
            for (int i = 0; i < currentLogCount; i++)
            {
                InformationLog informationLog1;
                InformationLogQueue.TryDequeue(out informationLog1);
                informationLogs.Add(informationLog1);
            }
    WriteToDatabase(informationLogs);
}

出列后，我将它传递给 LINQ 的插入方法，该方法需要将 InformationLog 列表插入到数据库中。

这是正确的方法还是有其他有效的方法？

Answer 1

您可以使用 ConcurrentQueue<T>通过这样的扩展方法直接在 Linq 语句中:

static IEnumerable<T> DequeueExisting<T>(this ConcurrentQueue<T> queue)
{
    T item;
    while (queue.TryDequeue(out item))
        yield return item;
}

这将使您不必不断分配新的 List<T>和 ConcurrentQueue<T>对象。