c# - Threadstart 在定时器的循环中只执行所述循环中的最后一个线程。

Question

我有一个计时器执行一个执行一系列线程的循环。每个线程简单地轮询串行设备(在唯一端口上)并将数据写入 MySQL 数据库以供 Web 应用程序获取。

我注意到只有循环中的最后一个线程正在执行。

这是我的计时器 Interval方法。

static void glob_timer_Elapsed(object sender, ElapsedEventArgs e)
{
    foreach (object[] row in user_ids)
    {
        Console.WriteLine(row[0].ToString() + ":" + row[1].ToString());
        ThreadStart starter = delegate { Functions.UpdateFor(row[0].ToString(), row[1].ToString()); };
        new Thread(starter).Start();
    }
}

user_ids 是 List<object[]>包含来自查询的行；所以row[0] = 用户 ID，row[1] = Com 端口名称

在函数中 UpdateFor() :

public static void UpdateFor(string uid, string com_name)
{
    try
    {
        Console.WriteLine("[" + uid + "]- " + DateTime.Now.ToString() + " : " + "Begin read transmission.");

运行时，在控制台中我看到

 1:COM1 
 2:COM2
 [2]-{DateTime} : Begin read transmission

为什么我没有看到 UpdateFor对于 uid 1。

注意:我还验证了应该从 COM1 写入数据库的数据从未被写入。

Answer 1

您遇到了关闭问题。每个委托(delegate)在每个循环、迭代中捕获对 object[] row 的引用，因此它们都使用相同的引用执行，即 row 的最终值是什么。您只需分配一个内部变量即可确保每个委托(delegate)都获得唯一的引用。

 foreach (object[] row in user_ids)
 {
    var innerReference = row;
    Console.WriteLine(innerReference[0].ToString() + ":" + innerReference[1].ToString());
    ThreadStart starter = delegate { Functions.UpdateFor(innerReference[0].ToString(), innerReference[1].ToString()); };
    new Thread(starter).Start();
 }