1

我是 C# 线程的新手，在实现基本任务时需要帮助。我目前正在使用下面的代码（不使用线程），它运行良好。这个概念是遍历表的记录，在函数中传递一些表参数，除了返回值，然后用返回值更新表。

cmd = new OleDbCommand { Connection = con, CommandText = "Select recid,col_A,col_B from tblData"};
dr = cmd.ExecuteReader();

if (dr.HasRows)
{
   cmdRec = new OleDbCommand { Connection = con };
   while (dr.Read())
    {
    sReqResult = DoProcessing(dr["col_A"].ToString(), dr["col_B"].ToString(), dr["PARAM2"].ToString());
        sSql = "update tblData set STATUS='" + sReqResult + "' where recid = '" + dr["recid"] + "'";
    cmdRec.CommandText = sSql;
    cmdRec.ExecuteNonQuery(); 
    }
}
dr.close();

我想使用线程来实现上述功能以加快进程，这样我就可以并行运行最多 25 个线程，而不是依次处理记录。但要求是从函数中获取返回值并在表中更新相同的值。我已经阅读了线程池和任务（在 .net 4.0 中），但我不确定如何实现它们。请用一些示例代码指导我。

4

2 回答 2

1

有了这个答案，我暗示您想自己创建异步实现，而不是使用现有的工具/库。

通常，您不能简单地从异步上下文中“返回”一个值。相反，您可以有一个带有某些“返回”参数（即结果）的回调。

带有线程池的概念示例：

if (dr.HasRows)
{
    object someDataToWorkWith = "data";

    Action<object> resultCallback = (theResults) =>
    {
        // Executed once the workItem is finished.
        // Work with and/or present the results here.
    };

    WaitCallback workItem = (dataOrSomeDetails) =>
    {
        // This is the main async-part. Work with or fetch data here.
        // You can also access any variables from the containing method.
        // When finished working, execute callback:
        resultCallback("someResults");
    };

    ThreadPool.QueueUserWorkItem(workItem, someDataToWorkWith);
}
于 2012-10-10T11:54:30.687 回答
0

为什么不使用异步ado.net 功能？

于 2012-10-10T11:36:35.340 回答