| | |
| | | { |
| | | List<Task> tasks = new List<Task>(); |
| | | |
| | | tasks.Add(GetTask(OutboundCore.CheckOutboundOrder)); |
| | | tasks.Add(GetTask(CheckCore.CheckOrderState)); |
| | | |
| | | tasks.Add(GetTask(OutboundCore.CheckOutboundTask)); |
| | | tasks.Add(GetTask(OutboundCore.CheckOrderState)); |
| | | |
| | | |
| | | // 添加任务推送线程 |
| | |
| | | Task.WaitAll(tasks.ToArray()); |
| | | } |
| | | public void Stop() { Console.WriteLine("work stopped"); } |
| | | private Task GetTask(Action action) |
| | | |
| | | private Task GetTask(Action action, int intervalMs = 3000) |
| | | { |
| | | var task = Task.Run(() => |
| | | { |
| | |
| | | { |
| | | LogHelper.Error(ex.Message, ex); |
| | | } |
| | | Thread.Sleep(3000); |
| | | Thread.Sleep(intervalMs); |
| | | } |
| | | }); |
| | | return task; |