在很多项目，很多开发人员认为如果数据量大，进行大批量计算等操作时，为了节省运行时间，在代码中启用并行操作，使用多个线程去计算，实际上如果系统本身可能并发比较多，如果再使用多线程，绝对会造成任务阻塞，反而造成系统动不了，影响整体系统使用，那对于大批量的数据比如成本计算通常是怎么做的？保证性能的呢？
一. 对于大批量计算，在开发中尽量少使用如下代码，必须考虑其阻塞现象，如下图画红圈部分代码。
二、计算功能放在计算服务里，不要放在主服务进行，比如成本计算就是这样做的。
计算服务实现方式参考：
【应用场景】一次性的，不需要周期性执行的，不需要界面交互的，高资源消耗型的后台任务。计算任务通过计算站点运行，能有效降低对应用站点的性能影响。
计算任务和执行计划都是运行在计算站点上，两者的主要区别在于，计算任务是即时启动任务，且仅执行一次；而执行计划是根据其定义的执行策略，周期性的执行。
【案例演示】实现一个计算任务，任务中实现写上机日志和发送邮件的功能，并在采购订单列表上启动该计算任务。
【实现步骤】
<1>编写计算任务服务类，代码如下。
using Kingdee.BOS.App.Core;
using Kingdee.BOS.Computing;
using Kingdee.BOS.Core.Log;
using Kingdee.BOS.Log;
using Kingdee.BOS.Util;
using System;
using System.Collections.Generic;
namespace Jac.XkDemo.BOS.App.PlugIn
{
/// <summary>
/// 【计算任务】从零开发计算任务
/// </summary>
public class SendMailComputeTaskService : IComputeTaskExecutor
{
/// <summary>
/// 计算任务入口函数
/// </summary>
/// <param name="ctx"></param>
public void Execute(ComputeContext ctx)
{
try
{
#region 计算任务主体逻辑
// TODO
// TODO
// TODO
#endregion
#region 写个上机操作日志，证明我执行过啦
var logs = new List<LogObject>();
var log = new LogObject();
log.pkValue = "0";
log.Description = "我是一条来自计算任务的测试日志数据:)";
log.OperateName = "执行计算任务";
log.ObjectTypeId = "BOS_COMPUTETASK";
log.SubSystemId = "BOS";
log.Environment = OperatingEnvironment.BizOperate;
logs.Add(log);
new Kingdee.BOS.App.LogService.Log().BatchWriteLog(ctx.Task.BOSContext, logs);
#endregion
#region 执行完了，发个邮件通知下用户
// 给当前用户发个邮件
var userId = ctx.Task.BOSContext.UserId;
var email = new SendMailService().GetEmailMessageInfoByUserId(ctx.Task.BOSContext, userId);
if (email != null)
{
email.To = new List<string>(new[] {"abc@qq.com"});
email.Subject = "计算任务测试邮件";
email.Body = "我是一封来自计算任务的测试邮件，计算任务已成功执行！";
MailUtils.Sendmail(email);
}
#endregion
}
catch (Exception ex)
{
var errMsg = string.Format("计算任务运行异常:{0}", ex.Message);
Logger.Error("Jac", errMsg, ex);
}
}
}
}
<2>编写列表插件，代码如下。
using Kingdee.BOS.App;
using Kingdee.BOS.Computing;
using Kingdee.BOS.Contracts.Computing;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.List.PlugIn;
using Kingdee.BOS.Util;
using System;
using System.Collections.Generic;
using System.ComponentModel;
namespace Jac.XkDemo.BOS.Business.PlugIn
{
/// <summary>
/// 【列表插件】启动计算任务
/// </summary>
[Description("【列表插件】启动计算任务"), HotUpdate]
public class SubmitComputeTaskListPlugIn : AbstractListPlugIn
{
public override void BarItemClick(BarItemClickEventArgs e)
{
base.BarItemClick(e);
if (e.BarItemKey.EndsWith("tbSubmitComputeTask", StringComparison.OrdinalIgnoreCase))
{
// 启动一个已经定义好的计算任务
var backAppService = ServiceHelper.GetService<IBackAppService>();
var backAppTask = new BackAppTask();
backAppTask.BOSContext = this.Context;
backAppTask.OriginatorId = this.Context.UserId;
backAppTask.ExecutorType = Type.GetType("Jac.XkDemo.BOS.App.PlugIn.SendMailComputeTaskService,Jac.XkDemo.BOS.App.PlugIn");
backAppTask.Title = "计算任务运行演示";
var properties = new Dictionary<string, object>();
properties.Add("自定义参数1", "a");
properties.Add("自定义参数2", "b");
backAppTask.Properties = properties;
backAppTask.Status = ComputeStatus.Ready;
backAppTask.Priority = ComputePriority.Immediately;
backAppTask.SerializeProperties();
backAppService.SubmitTask(this.Context, backAppTask);
this.View.ShowMessage("计算任务已启动！");
}
}
}
}
<3>拷贝插件组件到应用站点的WebSite\Bin目录下，重启IIS。
<4>BOSIDE扩展采购订单，列表菜单新增菜单项，注册列表插件，保存元数据，开发完毕。
现在可以登录业务站点，打开采购订单列表，启动计算任务啦。
启动计算任务：
查看计算任务执行情况：
计算任务执行成功后，写入了上机操作日志：
赞 4
打赏推荐阅读