如何从石英调度作业同步调用异步方法

Question

我正在尝试从我的 quartz.net 计划作业中调用 webapi 方法。我不确定我的做法是否正确？如果这是正确的方法或有更好的方法可用，任何人都可以提供帮助吗？

MethodRepository.cs

public async Task<IEnumerable<ResultClass>> GetResult(string queryCriteria)
{
    return await _httpClient.Get(queryCriteria);
}

石英作业：

public async void Execute(IJobExecutionContext context)
{
    var results= await _repo.GetResult();
}

通用 Httpclient ：

public async Task<IEnumerable<T>> Get(string queryCriteria)
{
    _addressSuffix = _addressSuffix + queryCriteria;
    var responseMessage = await _httpClient.GetAsync(_addressSuffix);
    responseMessage.EnsureSuccessStatusCode();
    return await responseMessage.Content.ReadAsAsync<IEnumerable<T>>();
}

但石英文档说我不能在石英作业中使用异步方法。那如何才能使用 Web API 方法呢？

我可以将石英作业执行方法更改为：

public void Execute(IJobExecutionContext context)
{
    var result = _repo.GetResult().Result;
}

Answer 1

Quartz.NET 3.0 支持开箱即用的异步/等待。因此，您现在可以（并且必须）将 Execute 方法声明为 Task 返回，并且可以使用 async/await。

public async Task Execute(IJobExecutionContext context)
{
    var result = await _repo.GetResult();
}

Answer 2

如果你必须这样做 - 那么你可以这样做，但它会阻塞调用线程，直到异步操作完成。

Task.Result 会将任何异常包装到 AggregateException 中。

所以你应该把你的 httpclient 调用放在 try catch 中。

  try
  {
      var result = _repo.GetResult().Result;
  }
  catch (AggregateException ae)
  {
      // handle exception
  }

另外，他们似乎正在处理AsyncJob。