我正在将IBackgroundJobManager
与Hangfire集成使用。
用例:
我正在处理一个上传的文件。保存文件后,我想依次启动两个单独的Abp.BackgroundJobs
。仅在第一个作业完成后应该启动第二个作业。
这是我的代码:
var measureJob1 = await _backgroundJobManager.EnqueueAsync<FileProcessBackgroundJob, FileProcessJobArgsDto>(
new FileProcessJobArgsDto
{
Id = Id,
User = user,
})
.ContinueWith<AnalyticsBackgroundJob<AnalyticsJobArgsDto>>("measureJob",x => x);
问题:
使用.ContinueWith<???>(???)
时我找不到所需的语法。
这似乎是XY Problem。
不支持保证作业的顺序和条件执行。
也就是说,后台作业会自动重试,这允许下面的方法3。
因此,您可以通过以下方式之一有效地实现这一目标:
ContinueWith
,await
更整洁)。在第二个作业中,检查第一个作业是否创建了所需的内容。否则,抛出异常并依靠重试。ContinueWith
时需要什么语法? (解决方案Y)没有语法,除了方法3的一个不太理想的变体。
[Task.ContinueWith
是在Task.ContinueWith
任务之后而不是实际的后台作业之后运行的C#构造。
带有EnqueueAsync
的方式3的语法类似于:
ContinueWith
比较为:
var measureJobId = await _backgroundJobManager.EnqueueAsync<FileProcessBackgroundJob, FileProcessJobArgsDto>(
new FileProcessJobArgsDto
{
Id = Id,
User = user,
}
)
.ContinueWith(task => _backgroundJobManager.EnqueueAsync<AnalyticsBackgroundJob, AnalyticsJobArgsDto>(
new AnalyticsJobArgsDto("measureJob")
)
.Unwrap();