zoukankan      html  css  js  c++  java
  • 单线程任务 Task.Factory.StartNew 封装

    代码:

    using log4net;
    using SunCreate.CombatPlatform.Security;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Windows.Threading;
    
    namespace SunCreate.CombatPlatform.Client
    {
        /// <summary>
        /// 线程帮助类(处理单线程任务)
        /// </summary>
        public class ThreadHelper
        {
            private static ILog _log = log4net.LogManager.GetLogger(typeof(ThreadHelper));
    
            /// <summary>
            /// 执行 
            /// 例:ThreadHelper.Run(() => { }, (ex) => { });
            /// </summary>
            /// <param name="doWork">在线程中执行</param>
            /// <param name="errorAction">错误处理</param>
            public 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 != null) doWork();
                    }
                    catch (Exception ex)
                    {
                        _log.Error("ThreadHelper.Run 错误", ex);
    
                        if (!SP.Get<IOnlineService>().GetNetStatus())
                        {
                            SP.Get<IUIManager>().Dispatcher.BeginInvoke(new Action(() =>
                            {
                                TaskDialog.Show("连接数据库失败,请联系系统管理员,给您带来不便,敬请谅解");
                            }));
                        }
                        else
                        {
                            SP.Get<IUIManager>().Dispatcher.BeginInvoke(new Action(() =>
                            {
                                new WaitingWindow("查询失败,请联系系统管理员,给您带来不便,敬请谅解").Show();
                            }));
                        }
    
                        if (errorAction != null) errorAction(ex);
                    }
                });
                return task;
            }
    
            /// <summary>
            /// 封装Dispatcher.BeginInvoke 
            /// 例:ThreadHelper.BeginInvoke(this.Dispatcher, () => { }, (ex) => { });
            /// </summary>
            /// <param name="errorAction">错误处理</param>
            public static void BeginInvoke(Dispatcher dispatcher, Action action, Action<Exception> errorAction = null)
            {
                dispatcher.BeginInvoke(new Action(() =>
                {
                    try
                    {
                        action();
                    }
                    catch (Exception ex)
                    {
                        _log.Error("ThreadHelper.BeginInvoke 错误", ex);
    
                        TaskDialog.Show("加载失败,请联系系统管理员,给您带来不便,敬请谅解");
    
                        if (errorAction != null) errorAction(ex);
                    }
                }));
            }
        }
    }
    View Code
  • 相关阅读:
    Oracle函数列表速查
    Oreilly.Oracle.PL.SQL.Language.Pocket.Reference.2nd.Edition.eBookLiB
    SAP 查询跟踪监控,sql 执行计划
    删除IDOC
    Oracle可变参数的优化(转)
    ORACLE用户连接的管理
    批量处理change pointer 生成IDOC
    设置SAP后台的显示和修改
    如何增加SAP_ALL的权限
    BizTalk开发小技巧分拆和组装消息实例
  • 原文地址:https://www.cnblogs.com/s0611163/p/9182523.html
Copyright © 2011-2022 走看看