| | |
| | | /// <summary> |
| | | /// 工作的线程 |
| | | /// </summary> |
| | | public class WorkThread |
| | | public class WorkThread |
| | | { |
| | | public void Start() |
| | | { |
| | |
| | | // Directory读取文件,并处理 |
| | | GetTask(DirectoryHelper.GainData), |
| | | // 出库agv任务推送 |
| | | GetTask(ThreadMenthod.DispatchFromAGV), |
| | | GetTaskS(ThreadMenthod.DispatchFromAGV), |
| | | // 读取线体信息并做对应的处理 |
| | | GetTask(ThreadMenthod.ReadConveyorlinesMessage), |
| | | GetTask(ThreadMenthod.ReadConveyorlinesMessage) |
| | | }; |
| | | Task.WaitAll(tasks.ToArray()); |
| | | } |
| | |
| | | |
| | | return task; |
| | | } |
| | | |
| | | private Task GetTaskS(Action action) |
| | | { |
| | | var task = Task.Run(() => |
| | | { |
| | | while (true) |
| | | { |
| | | try |
| | | { |
| | | action(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | LogHelper.Error(ex.Message, ex); |
| | | } |
| | | |
| | | Thread.Sleep(600000); |
| | | } |
| | | }); |
| | | |
| | | return task; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// ftp上传与下载 |