diff --git a/WarehouseMgr/Tnb.WarehouseMgr/TimedTaskBackgroundService.cs b/WarehouseMgr/Tnb.WarehouseMgr/TimedTaskBackgroundService.cs index d4a0612a..3061122f 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/TimedTaskBackgroundService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/TimedTaskBackgroundService.cs @@ -44,9 +44,10 @@ namespace Tnb.WarehouseMgr static TimedTaskBackgroundService() { _timedFuncMap = App.EffectiveTypes.AsParallel().Where(t => !t.Namespace.IsNullOrWhiteSpace() && t.Namespace.Contains("Tnb.WarehouseMgr")).SelectMany(t => t.GetMethods()) - .Where(m => m.GetCustomAttribute() != null) - .ToDictionary(x => x.Name, x => - (Func)Delegate.CreateDelegate(typeof(Func), App.GetService(x.DeclaringType), x)); + .Where(m => m.GetCustomAttribute() != null) + .ToDictionary(x => x.Name, x => + (Func)Delegate.CreateDelegate(typeof(Func), App.GetService(x.DeclaringType), x)); + } public TimedTaskBackgroundService(IServiceProvider serviceProvider) { @@ -59,7 +60,7 @@ namespace Tnb.WarehouseMgr var channelReader = _serviceProvider.GetRequiredService().Reader; CancellationTokenSource? cts = new(); - + while (channelReader != null && await channelReader.WaitToReadAsync()) { while (channelReader.TryRead(out var message))