| | |
| | | |
| | | List<Task> tasks = new List<Task>(); |
| | | |
| | | //小车动作缓存处理 |
| | | tasks.Add(GetTask1(Monitor.agvActionManage)); |
| | | |
| | | |
| | | //添加agv任务推送线程 |
| | | tasks.Add(GetTask(TaskCore.Dispatch)); |
| | |
| | | |
| | | //空托自动出库 |
| | | tasks.Add(GetTask(Monitor.ktAuto)); |
| | | |
| | | |
| | | //根据配置,每间隔多少分钟提高多少优先级 |
| | | tasks.Add(GetTask(Monitor.UpdateOutTaskPriority)); |
| | | |
| | | |
| | | } |
| | | public void Stop() { Console.WriteLine("work stopped"); } |
| | |
| | | }); |
| | | return task; |
| | | } |
| | | |
| | | |
| | | private Task GetTask1(Action action) |
| | | { |
| | | var task = Task.Run(() => { |
| | | while (true) |
| | | { |
| | | try |
| | | { |
| | | action(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | LogHelper.Error(ex.Message, ex); |
| | | } |
| | | Thread.Sleep(200); |
| | | } |
| | | }); |
| | | return task; |
| | | } |
| | | } |
| | | } |
| | | } |