项目中的代码记录日常

/// <summary>
/// 修改任务状态
/// </summary>
private void StartProcess21()
{Process21Task = new Thread(() =>{while (CommonUtility.IsWorking){try{if (tPAgvTasksList.Count > 0){Parallel.ForEach(tPAgvTasksList, new ParallelOptions() { MaxDegreeOfParallelism = 16 }, item =>{// 判断 一期 或 二期//var StagePlc = item.Stage == 1 ? PlcDevice1 : PlcDevice2;// 通知PLC动作完成PlcDevice1.Write(item.DbChunk, WriteNumber);PlcDevice2.Write(item.DbChunk, WriteNumber);Logger.Info($"PLC写入状态 , 偏移量：{item.DbChunk}；订单：{item.OrderId};状态：{item.Status}");int Id = item.Id;int Sign = 1;// 修改数据库查询标记并保存_repository.UpdateTask(Id, Sign);ListItem = item;});// 移除当前对象tPAgvTasksList.Remove(ListItem);Logger.Info($"当前数据数量为：{tPAgvTasksList.Count()};");}}catch (Exception ex){Logger.Error($"异常信息：{ex.Message}");}// 短暂休眠Thread.Sleep(DormancyTimeCount);}});Process21Task.IsBackground = true;Process21Task.Start();
}

详细解释

1. 方法定义

private void StartProcess21()
定义了一个名为 StartProcess21 的私有方法，用于启动一个线程来修改任务状态。

2. 创建线程

Process21Task = new Thread(() =>
创建一个新的线程 Process21Task，并使用 lambda 表达式定义线程的主体。

3. 循环条件

while (CommonUtility.IsWorking)
线程将在 CommonUtility.IsWorking 为 true 时持续运行。

4. 异常处理

try
{// 代码块
}
catch (Exception ex)
{Logger.Error($"异常信息：{ex.Message}");
}
使用 try-catch 块捕获可能的异常，并在日志中记录异常信息。

5. 检查任务列表

if (tPAgvTasksList.Count > 0)
检查 tPAgvTasksList 列表中是否有任务需要处理。

6. 并行处理任务

Parallel.ForEach(tPAgvTasksList, new ParallelOptions() { MaxDegreeOfParallelism = 16 }, item =>
{// 代码块
});
使用 Parallel.ForEach 并行处理 tPAgvTasksList 中的每个任务，最大并行度为 16。

7. PLC写入操作

PlcDevice1.Write(item.DbChunk, WriteNumber);
PlcDevice2.Write(item.DbChunk, WriteNumber);
Logger.Info($"PLC写入状态 , 偏移量：{item.DbChunk}；订单：{item.OrderId};状态：{item.Status}");
向 PlcDevice1 和 PlcDevice2 写入状态，并在日志中记录写入信息。

8. 更新数据库标记

int Id = item.Id;
int Sign = 1;
_repository.UpdateTask(Id, Sign);
获取任务的 Id 和设置标记 Sign 为 1，然后调用 _repository.UpdateTask 方法更新数据库中的任务标记。

9. 移除已经处理任务

ListItem = item;
tPAgvTasksList.Remove(ListItem);
Logger.Info($"当前数据数量为：{tPAgvTasksList.Count()};");
将当前处理的任务赋值给 ListItem，然后从 tPAgvTasksList 中移除该任务，并在日志中记录当前任务列表的数量。

10. 短暂休眠

Thread.Sleep(DormancyTimeCount);
线程休眠一段时间，避免过度占用 CPU 资源。

11. 设置线程为后台线程并启动

Process21Task.IsBackground = true;
Process21Task.Start();
将 Process21Task 设置为后台线程并启动。

总结
该代码的主要功能是启动一个后台线程，定期检查并处理任务列表中的任务。具体步骤包括：

检查任务列表中是否有任务需要处理。
并行处理每个任务，向 PLC 设备写入状态并更新数据库中的任务标记。
从任务列表中移除已处理的任务。
在日志中记录相关信息。
线程休眠一段时间后继续检查任务列表。
通过这种方式，代码实现了任务状态的异步更新和处理，确保系统的高效运行。