2

我试图实现的是在不同的线程中为集合中的每个值执行一个方法。我想测量完成所有任务所经过的时间。我的代码如下：

private ConcurrentQueue<string> Results { get; set; }
public System.Threading.Timer Updater { get; set; }
private Dictionary<int, string> Instances { get; set; }

        private void Button_Click(object sender, RoutedEventArgs e)
        {
            this.Instances = new Dictionary<int, string>();

            this.Instances.Add(01, "A");
            this.Instances.Add(02, "B");
            this.Instances.Add(03, "C");
            this.Instances.Add(04, "D");
            this.Instances.Add(05, "E");
            this.Instances.Add(06, "F");
            this.Instances.Add(07, "G");
            this.Instances.Add(08, "H");
            this.Instances.Add(09, "I");
            this.Instances.Add(10, "J");

            this.Updater = 
            new System.Threading.Timer(new TimerCallback(Updater_CallBack), null, 0, 1000);
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="State"></param>
        void Updater_CallBack(object State)
        {
            this.Operation();
        }

        private void Operation()
        {
            var Watcher = new System.Diagnostics.Stopwatch();
            Watcher.Restart();

            this.Results = new ConcurrentQueue<string>();

            var Tasks = new System.Threading.Tasks.Task[this.Instances.Count];

            int i = 0;

            foreach (var Pair in this.Instances)
            {
                Tasks[i] = Task.Factory.StartNew(() => { this.Tasker(Pair.Value); });
                i++;
            }

            System.Threading.Tasks.Task.WaitAll(Tasks);

            Watcher.Stop();

            var Text = new StringBuilder();
            foreach (var Result in Results) Text.Append(Result);
            System.IO.File.AppendAllText(@"D:\Tasks.TXT", Watcher.ElapsedMilliseconds.ToString() + "   " + Text.ToString() + Environment.NewLine);           
        }

        private void Tasker(string Id)
        {
            switch (Id)
            {
                case "A": Thread.Sleep(100); this.Results.Enqueue("a"); break;
                case "B": Thread.Sleep(100); this.Results.Enqueue("b"); break;
                case "C": Thread.Sleep(100); this.Results.Enqueue("c"); break;
                case "D": Thread.Sleep(100); this.Results.Enqueue("d"); break;
                case "E": Thread.Sleep(100); this.Results.Enqueue("e"); break;
                case "F": Thread.Sleep(100); this.Results.Enqueue("f"); break;
                case "G": Thread.Sleep(100); this.Results.Enqueue("g"); break;
                case "H": Thread.Sleep(100); this.Results.Enqueue("h"); break;
                case "I": Thread.Sleep(100); this.Results.Enqueue("i"); break;
                case "J": Thread.Sleep(100); this.Results.Enqueue("j"); break;
            }
        }

我在这里期望的是 Tasker 方法执行 10 次，但每次执行不同的结果。当我查看我的结果时，我看到以下内容：

200   jjjjjjjjjj
101   jjjjjjgjjj
101   hhhhhhhhjj
101   hjjjjjjjjj
101   jjjjjjjjhj
100   jjjjjjjjjh
101   jjjjjjjjjj

Tasker 方法多次执行'j'。我无法弄清楚为什么不对集合中的其他字母执行该方法。我在这里想念什么？

4

1 回答 1

1

我认为本质上问题在于您正在Pair从传递给 Task.Factory.StartNew 的操作中访问变量。

foreach (var Pair in this.Instances)
{
    Tasks[i] = Task.Factory.StartNew(() => { this.Tasker(Pair.Value); });
    i++;
}

您必须意识到这意味着您没有立即读取变量“Pair”，而是告诉任务工厂将线程池线程排队。然后当该线程启动时（这可能发生在一个不确定的时间间隔之后），您正在访问该线程的本地范围内的一个变量，该变量已经更改，因为 foreach 循环没有等待任务开始。

你可以像这样修复它：

foreach (var Pair in this.Instances)
{
    var currentValue = Pair.Value;
    Tasks[i] = Task.Factory.StartNew(() => { this.Tasker(currentValue); });
    i++;
}

现在，您正在为 foreach 的每次迭代创建一个单独的本地范围变量，这不应该改变您。

顺便说一句，我认为您的代码的一个单独的逻辑问题是您在外循环的每次迭代中重用相同的 ConcurrentQueue 引用，但您每次都在更改它。你根本不应该有这条​​线：

private ConcurrentQueue<string> Results { get; set; }

您应该使用一些更好的方法来管理每个线程组的结果。在这种情况下，您可以使用 ConcurrentQueue 的 ConcurrentQueues ......但我个人会改为使用任务参数。在您的方法中本地创建 ConcurrentQueueOperation并将其作为辅助参数传递给 Tasker 方法。

于 2013-09-27T17:39:22.183 回答