dotnet-campus/dotnetCampus.ApplicationStartupManager
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

全面干掉配置相关逻辑

Browse Source
This commit is contained in:
lindexi
2022-03-02 12:08:10 +08:00
parent 426a0b7a76
commit ccee508e75
3 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/dotnetCampus.ApplicationStartupManager/IStartupContext.cs
View File

@@ -1,12 +1,12 @@
using System.Threading.Tasks;
using dotnetCampus.Configurations;
//using dotnetCampus.Configurations;
namespace dotnetCampus.ApplicationStartupManager
{
public interface IStartupContext
{
IAppConfigurator Configs { get; }
Task<string> ReadCacheAsync(string key, string @default = "");
//IAppConfigurator Configs { get; }
//Task<string> ReadCacheAsync(string key, string @default = "");
Task WaitStartupTaskAsync(string startupKey);
}
}

22
src/dotnetCampus.ApplicationStartupManager/StartupContext.cs
View File

@@ -1,7 +1,7 @@
using System;
using System.Threading.Tasks;
using dotnetCampus.Configurations;
using dotnetCampus.Configurations.Core;
//using dotnetCampus.Configurations;
//using dotnetCampus.Configurations.Core;
namespace dotnetCampus.ApplicationStartupManager
{
@@ -9,28 +9,28 @@ namespace dotnetCampus.ApplicationStartupManager
{
public IStartupLogger Logger { get; }
public FileConfigurationRepo Configuration { get; }
//public FileConfigurationRepo Configuration { get; }
public IAppConfigurator Configs { get; }
//public IAppConfigurator Configs { get; }
public Func<Exception, Task> FastFail { get; }
private readonly Func<string, Task> _waitStartupTaskAsync;
public Task<string> ReadCacheAsync(string key, string @default = "")
{
return Configuration.TryReadAsync(key, @default);
}
//public Task<string> ReadCacheAsync(string key, string @default = "")
//{
// return Configuration.TryReadAsync(key, @default);
//}
Task IStartupContext.WaitStartupTaskAsync(string startupKey) => _waitStartupTaskAsync(startupKey);
public StartupContext(IStartupLogger logger, FileConfigurationRepo configuration,
public StartupContext(IStartupLogger logger, /*FileConfigurationRepo configuration,*/
Func<Exception, Task> fastFailAction, Func<string, Task> waitStartupAsync)
{
Logger = logger;
Configuration = configuration;
//Configuration = configuration;
_waitStartupTaskAsync = waitStartupAsync;
Configs = configuration.CreateAppConfigurator();
//Configs = configuration.CreateAppConfigurator();
FastFail = fastFailAction ?? (exception => StartupTask.CompletedTask);
}
}

14
src/dotnetCampus.ApplicationStartupManager/StartupManager.cs
View File

@@ -8,7 +8,7 @@ using System.Net.Mime;
using System.Reflection;
using System.Threading;
using System.Threading.Tasks;
using dotnetCampus.Configurations.Core;
//using dotnetCampus.Configurations.Core;
namespace dotnetCampus.ApplicationStartupManager
{
@@ -48,7 +48,7 @@ namespace dotnetCampus.ApplicationStartupManager
private IStartupLogger Logger => Context.Logger;
public StartupManager(IStartupLogger logger, FileConfigurationRepo configurationRepo,
public StartupManager(IStartupLogger logger, /*FileConfigurationRepo configurationRepo,*/
Func<Exception, Task> fastFailAction, IMainThreadDispatcher dispatcher, bool shouldSetThreadPool = true)
{
if (logger == null)
@@ -56,10 +56,10 @@ namespace dotnetCampus.ApplicationStartupManager
throw new ArgumentNullException(nameof(logger));
}
if (configurationRepo is null)
{
throw new ArgumentNullException(nameof(configurationRepo));
}
//if (configurationRepo is null)
//{
// throw new ArgumentNullException(nameof(configurationRepo));
//}
_dispatcher = dispatcher;
@@ -71,7 +71,7 @@ namespace dotnetCampus.ApplicationStartupManager
ThreadPool.SetMinThreads(Math.Max(_workerThreads, 16), Math.Max(_completionPortThreads, 16));
}
Context = new StartupContext(logger, configurationRepo,
Context = new StartupContext(logger, /*configurationRepo,*/
fastFailAction, WaitStartupTaskAsync);
Logger.RecordTime("ManagerInitialized");