如何将任务并行库与 DataReader 结合使用

我经常用数据填充数据读取器并像这样填充 UI

using (SqlConnection conn = new SqlConnection("myConnString"))
using (SqlCommand comm = new SqlCommand("Select * from employee where salary<5000", conn))
{
    conn.Open();

    SqlDataReader reader = comm.ExecuteReader();

    if (reader.HasRows)
    {
        while (reader.Read())
        {
            // here i populate my employee class
        }
    }
    // here i update UI
}

我正在搜索任务并行库与 DataReader 的使用并找到了一段代码。它看起来不错，但目标对我来说不是很清楚。这是我得到的代码。

public IEnumerable<MyDataClass> ReadData()
{
using (SqlConnection conn = new SqlConnection("myConnString"))
using (SqlCommand comm = new SqlCommand("myQuery", conn))
{
    conn.Open();

    SqlDataReader reader = comm.ExecuteReader();

    if (reader.HasRows)
    {
        while (reader.Read())
        {
            yield return new MyDataClass(... data from reader ...);
        }
    }
}
}

打电话像

Parallel.ForEach(this.ReadData(), data =>
{
// Use the data here...
});

OR

this.ReadData().AsParallel().ForAll(data => 
{
// Use the data here...
});

我怎样才能从中获取数据ForAll.

任何人都可以帮助我理解代码片段，它是如何工作的以及如何从中获取数据ForAll我如何填充我的用户界面ForAll.

另一个问题是我如何知道哪个类是线程安全的。线程安全是什么意思。有人说 datareader 不是线程安全的。他怎么知道。

何时应该使用任务并行库的另一个问题。 请指导。谢谢

您可以在 MSDN 文档的 .NET 基类库中找到有关每种类型的线程安全性的信息。大多数类型是not线程安全。SqlDataReader例如，是not线程安全，因为它在与数据库的单个连接上工作。

然而，Parallel.ForEach是一个非常清晰的结构。你不能真正迭代IEnumerable同时使用多个线程，并且Parallel.ForEach不这样做。尽管它启动了多个线程并且这些多个线程确实在给定的IEnumerable, Parallel.ForEach确保仅one迭代枚举时的线程IEnumerator。它的运行假设是处理元素比从可枚举中获取项目花费更多的时间。迭代可枚举是一个顺序操作。

这意味着即使底层数据源和使用SqlReader不是线程安全的，您仍然可以使用并行处理项目Parallel.ForEach。不幸的是，MSDN 文档对此不是很明确，但必须如此，因为IEnumerator返回的实例GetEnumerator()方法从来都不是线程安全的。

但你仍然必须确保给定的Action<T>当然是线程安全的。

您可以使用以下程序查看此行为：

public static IEnumerable<int> GetNumbers()
{
    for (int i = 0; i < 140; i++)
    {
        Console.WriteLine(
            "                          Enumerating " + 
            i + " at thread " +
            Thread.CurrentThread.ManagedThreadId);

        yield return i;
    }
}

static void Main(string[] args)
{
    Console.ReadLine();

    Parallel.ForEach(GetNumbers(), number =>
    {
        Console.WriteLine("Processing " + number + 
            " at thread " +
            Thread.CurrentThread.ManagedThreadId);

        Thread.Sleep(1);
    });
}