c# – 如何正确等待调用Dispatcher.Invoke的多个线程在WPF应用程序中完成

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c# – 如何正确等待调用Dispatcher.Invoke的多个线程在WPF应用程序中完成，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3597字，纯文字阅读大概需要6分钟。

内容图文

我有一个WPF应用程序启动3个线程,需要等待它们完成.我在这里阅读了许多处理此问题的帖子,但似乎没有解决线程代码调用Dispatcher.Invoke或Dispatcher.BeginInvoke的情况.如果我使用线程的Join()方法或ManualResetEvent,则线程会在Invoke调用上阻塞.这是一个丑陋的解决方案的简化代码片段似乎有效：

class PointCloud
{
    private Point3DCollection points = new Point3DCollection(1000);
    private volatile bool[] tDone = { false, false, false };
    private static readonly object _locker = new object();

    public ModelVisual3D BuildPointCloud()
    {
        ...
        Thread t1 = new Thread(() => AddPoints(0, 0, 192));
        Thread t2 = new Thread(() => AddPoints(1, 193, 384));
        Thread t3 = new Thread(() => AddPoints(2, 385, 576));
        t1.Start();
        t2.Start();
        t3.Start();

        while (!tDone[0] || !tDone[1] || !tDone[2]) 
        {
            Dispatcher.CurrentDispatcher.Invoke(DispatcherPriority.Background, new ThreadStart(delegate { }));
            Thread.Sleep(1);
        }

        ...
    }

    private void AddPoints(int scanNum, int x, int y)
    {
        for (int i = 0; i < x; i++)
        {
            for (int j = 0; j < y; j++)
            {
                z = FindZ(x, y);

                if (z == GOOD_VALUE)
                {
                    Application.Current.Dispatcher.Invoke(DispatcherPriority.Normal,
                      (ThreadStart)delegate()
                      {
                          Point3D newPoint = new Point3D(x, y, z);
                          lock (_locker)
                          {
                              points.Add(newPoint);
                          }
                      }
                  );
                } 
            }
        }
        tDone[scanNum] = true;
    }
}

from the main WPF thread...
PointCloud pc = new PointCloud();
ModelVisual3D = pc.BuildPointCloud();
...

任何关于如何改进此代码的想法都将非常感激.看起来这应该是一个非常普遍的问题,但我似乎无法在任何地方找到它.

解决方法:

假设您可以使用.NET 4,我将向您展示如何以更清晰的方式执行此操作,以避免跨线程共享可变状态(从而避免锁定).

class PointCloud
{
    public Point3DCollection Points { get; private set; }

    public event EventHandler AllThreadsCompleted;

    public PointCloud()
    {
        this.Points = new Point3DCollection(1000);

        var task1 = Task.Factory.StartNew(() => AddPoints(0, 0, 192));
        var task2 = Task.Factory.StartNew(() => AddPoints(1, 193, 384));
        var task3 = Task.Factory.StartNew(() => AddPoints(2, 385, 576));
        Task.Factory.ContinueWhenAll(
            new[] { task1, task2, task3 }, 
            OnAllTasksCompleted, // Call this method when all tasks finish.
            CancellationToken.None, 
            TaskContinuationOptions.None,
            TaskScheduler.FromCurrentSynchronizationContext()); // Finish on UI thread.
    }

    private void OnAllTasksCompleted(Task<List<Point3D>>[] completedTasks)
    {
        // Now that we've got our points, add them to our collection.
        foreach (var task in completedTasks)
        {
            task.Result.ForEach(point => this.points.Add(point));
        }

        // Raise the AllThreadsCompleted event.
        if (AllThreadsCompleted != null)
        {
            AllThreadsCompleted(this, EventArgs.Empty);
        }
    }

    private List<Point3D> AddPoints(int scanNum, int x, int y)
    {
       const int goodValue = 42;
       var result = new List<Point3D>(500);
       var points = from pointX in Enumerable.Range(0, x)
                    from pointY in Enumerable.Range(0, y)
                    let pointZ = FindZ(pointX, pointY)
                    where pointZ == goodValue
                    select new Point3D(pointX, pointX, pointZ);
       result.AddRange(points);
       return result;
    }
}

消费这门课很容易：

// On main WPF UI thread:
var cloud = new PointCloud();
cloud.AllThreadsCompleted += (sender, e) => MessageBox.Show("all threads done! There are " + cloud.Points.Count.ToString() + " points!");

这种技术的解释

考虑以不同方式进行线程化：而不是尝试将线程访问同步到共享数据(例如,您的点列表),而是在后台线程上做大量工作,但不要改变任何共享状态(例如,不要向点列表添加任何内容) .对我们来说,这意味着循环遍历X和Y并找到Z,但不将它们添加到后台线程中的点列表中.一旦我们创建了数据,让UI线程知道我们已经完成并让他负责将点添加到列表中.

这种技术的优点是不共享任何可变状态 – 只有1个线程访问点集合.它还具有不需要任何锁定或显式同步的优点.

它有另一个重要特征：你的UI线程不会阻塞.这通常是一件好事,您不希望您的应用程序显示为冻结.如果要求阻止UI线程,我们必须稍微重做这个解决方案.

内容总结

以上是互联网集市为您收集整理的c# – 如何正确等待调用Dispatcher.Invoke的多个线程在WPF应用程序中完成全部内容，希望文章能够帮你解决c# – 如何正确等待调用Dispatcher.Invoke的多个线程在WPF应用程序中完成所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端