119 lines
3.4 KiB
C#
119 lines
3.4 KiB
C#
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using System.Timers;
|
|
using Autofac;
|
|
using CommonClass.Factory;
|
|
|
|
namespace CmdjyHisFront.Bll
|
|
{
|
|
public interface ITask
|
|
{
|
|
void Run();
|
|
}
|
|
/// <summary>
|
|
/// 任务管理器
|
|
/// </summary>
|
|
public interface ITaskManager
|
|
{
|
|
/// <summary>
|
|
/// 心跳间隔。毫秒
|
|
/// </summary>
|
|
double BackgroundTaskHeartbeat { get; set; }
|
|
|
|
/// <summary>
|
|
/// 执行任务
|
|
/// </summary>
|
|
void Start();
|
|
/// <summary>
|
|
/// 结束任务
|
|
/// </summary>
|
|
void Stop();
|
|
}
|
|
/// <summary>
|
|
/// 背景任务注册管理器
|
|
/// </summary>
|
|
public class TaskManagerRegister:IRegister
|
|
{
|
|
public void Register(ContainerBuilder builder) {
|
|
builder.Register<ITaskManager>(c => new TaskManager());
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 背景任务管理器
|
|
/// </summary>
|
|
public class TaskManager:ITaskManager
|
|
{
|
|
/// <summary>
|
|
/// 任务心跳触发计时器
|
|
/// </summary>
|
|
public static Timer CTimer { get; private set; }
|
|
|
|
/// <summary>
|
|
/// 要执行的背景线程
|
|
/// </summary>
|
|
public IEnumerable<ITask> BackTasks { get; set; }
|
|
|
|
public double BackgroundTaskHeartbeat { get; set; } = 1000;
|
|
|
|
/// <summary>
|
|
/// 创建一个背景任务管理器
|
|
/// </summary>
|
|
public TaskManager() { }
|
|
|
|
/// <summary>
|
|
/// 通过提供任务和背景心跳间隔创建背景任务管理器
|
|
/// </summary>
|
|
/// <param name="bt">背景任务枚举</param>
|
|
/// <param name="bh">心跳</param>
|
|
public TaskManager(IEnumerable<ITask> bt) {
|
|
this.BackTasks = bt;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 通过提供任务和背景心跳间隔创建背景任务管理器
|
|
/// </summary>
|
|
/// <param name="bt">背景任务枚举</param>
|
|
/// <param name="bh">心跳</param>
|
|
public TaskManager(IEnumerable<ITask> bt,double bh) {
|
|
this.BackTasks = bt; this.BackgroundTaskHeartbeat = bh;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 开始执行背景任务
|
|
/// </summary>
|
|
public void Start() {
|
|
if(this.BackTasks == null || this.BackTasks.Count() == 0) return;
|
|
CTimer = CTimer ?? new Timer(this.BackgroundTaskHeartbeat);
|
|
CTimer.Elapsed += this.run;
|
|
CTimer.AutoReset = false;
|
|
CTimer.Start();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 任务处理事件
|
|
/// </summary>
|
|
private void run(object sender,ElapsedEventArgs e) {
|
|
//启动具体任务
|
|
foreach(var t in this.BackTasks) {
|
|
Task.Factory.StartNew(m => {
|
|
if(m is ITask task) {
|
|
task.Run();
|
|
}
|
|
},t as object);
|
|
}
|
|
//任务启动后重启心跳计时器
|
|
if(sender is Timer timer) {
|
|
timer.Start();
|
|
}
|
|
}
|
|
|
|
public void Stop() {
|
|
if(CTimer == null) return;
|
|
CTimer.Stop();
|
|
CTimer.Elapsed -= run;
|
|
CTimer = null;
|
|
}
|
|
}
|
|
} |