#星空云诊所#在开发中使用并行多线程操作一定能提高运行速度吗?
在很多项目,很多开发人员认为如果数据量大,进行大批量计算等操作时,为了节省运行时间,在代码中启用并行操作,使用多个线程去计算,实际上如果系统本身可能并发比较多,如果再使用多线程,绝对会造成任务阻塞,反而造成系统动不了,影响整体系统使用,那对于大批量的数据比如成本计算通常是怎么做的?保证性能的呢?
一. 对于大批量计算,在开发中尽量少使用如下代码,必须考虑其阻塞现象,如下图画红圈部分代码。
二、计算功能放在计算服务里,不要放在主服务进行,比如成本计算就是这样做的。
计算服务实现方式参考:
【应用场景】一次性的,不需要周期性执行的,不需要界面交互的,高资源消耗型的后台任务。计算任务通过计算站点运行,能有效降低对应用站点的性能影响。
计算任务和执行计划都是运行在计算站点上,两者的主要区别在于,计算任务是即时启动任务,且仅执行一次;而执行计划是根据其定义的执行策略,周期性的执行。
【案例演示】实现一个计算任务,任务中实现写上机日志和发送邮件的功能,并在采购订单列表上启动该计算任务。
【实现步骤】
<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扩展采购订单,列表菜单新增菜单项,注册列表插件,保存元数据,开发完毕。
现在可以登录业务站点,打开采购订单列表,启动计算任务啦。
启动计算任务:
查看计算任务执行情况:
计算任务执行成功后,写入了上机操作日志:
#星空云诊所#在开发中使用并行多线程操作一定能提高运行速度吗?
本文2024-09-16 18:34:08发表“云星空知识”栏目。
本文链接:https://wenku.my7c.com/article/kingdee-k3cloud-23000.html