单线程任务 Task.Factory.StartNew 封装

代码：

using log4net;
 SunCreate.CombatPlatform.Security;
 System;
 System.Collections.Generic;
 System.Linq;
 System.Text;
 System.Windows.Threading;

namespace SunCreate.CombatPlatform.Client
{
    /// @H_404_33@<summary>
    @H_404_33@/// 线程帮助类(处理单线程任务)
    @H_404_33@</summary>
    public class ThreadHelper
    {
        private static ILog _log = log4net.LogManager.GetLogger(typeof(ThreadHelper));

        @H_404_33@<summary>
        @H_404_33@ 执行 
        @H_404_33@ 例：ThreadHelper.Run(() => { },(ex) => { });
        @H_404_33@</summary>
        @H_404_33@<param name="doWork">在线程中执行@H_404_33@</param>
        @H_404_33@<param name="errorAction">错误处理@H_404_33@</param>
        static System.Threading.Tasks.Task Run(Action doWork,Action<Exception> errorAction = null)
        {
            System.Threading.Tasks.Task task = System.Threading.Tasks.Task.Factory.StartNew(() =>
            {
                try
                {
                    if (doWork != ) doWork();
                }
                catch (Exception ex)
                {
                    _log.Error(@H_404_33@"@H_404[email protected] 错误@H_404_33@",ex);

                    if (!SP.Get<IOnlineservice>().GetNetStatus())
                    {
                        SP.Get<iuiManager>().dispatcher.BeginInvoke(new Action(() =>
                        {
                            TaskDialog.Show(@H_404_33@连接数据库失败，请联系系统管理员，给您带来不便，敬请谅解@H_404_33@);
                        }));
                    }
                    else
                    {
                        SP.Get<iuiManager>().dispatcher.BeginInvoke(
                        {
                            new WaitingWindow(@H_404_33@查询失败，请联系系统管理员，给您带来不便，敬请谅解@H_404_33@).Show();
                        }));
                    }

                    if (errorAction != ) errorAction(ex);
                }
            });
            return task;
        }

        @H_404_33@ 封装dispatcher.BeginInvoke 
        @H_404_33@ 例：ThreadHelper.BeginInvoke(this.dispatcher,() => { },1)">static void BeginInvoke(dispatcher dispatcher,Action action,1)">)
        {
            dispatcher.BeginInvoke(
                {
                    action();
                }
                ThreadHelper.BeginInvoke 错误404_33@加载失败，请联系系统管理员，给您带来不便，敬请谅解@H_404_33@);

                    ) errorAction(ex);
                }
            }));
        }
    }
}

View Code