Skip to content

添加并行构建功能，添加依赖任务配置 #66

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Ahoo-Wang merged 8 commits into from
May 7, 2022
Merged

添加并行构建功能，添加依赖任务配置 #66

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
704734f
添加多少线程构建，添加WaitPre
Mar 11, 2022
b631dc0
单个任务内并行生成
XiaoHeitu Mar 13, 2022
724bf74
单任务多线程
Mar 13, 2022
c2a4da8
添加任务依赖
XiaoHeitu Mar 14, 2022
e65bb90
Merge branch '优化_多线程构建' of https://github.com/XiaoHeitu/SmartCode int…
XiaoHeitu Mar 14, 2022
96f10dc
提交
XiaoHeitu Mar 14, 2022
43eb0ad
完善任务依赖，移除单任务并行代码
Mar 15, 2022
f0cd498
为项目添加 AllowParallel 配置。当AllowParallel 为false 或者AllowParallel 不存在时，忽略D…
Mar 15, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
单任务多线程
  • Loading branch information
yuanwj
yuanwj committed Mar 13, 2022
commit 724bf74b889517a355687c3d427cfb269dc24e90
19 changes: 12 additions & 7 deletions src/SmartCode.Generator/BuildTasks/TableBuildTask.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,11 @@ public override async Task Build(BuildContext context)
var filterTables = FilterTable(context.GetDataSource<ITableSource>().Tables, context.BuildKey,
context.Build);
context.SetCurrentAllTable(filterTables);

var nameConverter = _pluginManager.Resolve<INamingConverter>();
var templateEngine = _pluginManager.Resolve<ITemplateEngine>(context.Build.TemplateEngine.Name);
var output = _pluginManager.Resolve<IOutput>(context.Build.Output.Type);

var tasks = filterTables.Select(table =>
{
BuildContext newContext = new BuildContext();
Expand All @@ -40,20 +45,20 @@ public override async Task Build(BuildContext context)
newContext.Output = context.Output;
newContext.SetCurrentTable(table);

return BuildTable(newContext);
return Task.Factory.StartNew(BuildTable,(newContext, nameConverter, templateEngine, output), TaskCreationOptions.LongRunning);
}).ToArray();

await Task.WhenAll(tasks);
}

private async Task BuildTable(BuildContext context)
private async void BuildTable(object obj)
{
var table = context.GetCurrentTable();
var p=((BuildContext context, INamingConverter nameConverter, ITemplateEngine templateEngine, IOutput output)) obj;
var table = p.context.GetCurrentTable();
_logger.LogInformation($"BuildTable:{table.Name} Start!");
_pluginManager.Resolve<INamingConverter>().Convert(context);
context.Result = await _pluginManager.Resolve<ITemplateEngine>(context.Build.TemplateEngine.Name)
.Render(context);
await _pluginManager.Resolve<IOutput>(context.Build.Output.Type).Output(context);
p.nameConverter.Convert(p.context);
p.context.Result = await p.templateEngine.Render(p.context);
await p.output.Output(p.context);
_logger.LogInformation($"BuildTable:{table.Name} End!");
}

Expand Down