将sync方法转换为与C#异步

本文关键字：异步 转换 sync 方法 | 更新日期: 2024-09-22 18:29:15

我有两个方法。我想等第一个，有时还想等另一个（但不是一直等）。所以我认为我应该使用一个任务，在我想等待的时候等待它，而不是在我不想等待的情况下等待它。

编辑：事实上，我只需要一个火和忘记的电话？：

public class TestController : ApiController
{
    public IHttpActionResult Get(int id)
    {
        Stopwatch sw = Stopwatch.StartNew();
        JobRunner runner = new JobRunner();
        bool iWantToWait = id == 1;
        string jobId = runner.Run(!iWantToWait);
        sw.Stop();
        return Ok("Ok " + jobId + " # " + sw.Elapsed );
    }
}
public class JobRunner
{
    public string Run(bool fireAndForget)
    {
        ShortMethodIAlwaysWantToWait();
        string jobId = Guid.NewGuid().ToString("N");
        if (fireAndForget)
            HostingEnvironment.QueueBackgroundWorkItem(token => LongMethodICouldWantToWaitOrNot(jobId));
        else
            LongMethodICouldWantToWaitOrNot(jobId);
        return jobId;
    }
    private void ShortMethodIAlwaysWantToWait()
    {
        // ...
    }
    private void LongMethodICouldWantToWaitOrNot(string jobId)
    {
        // ...
    }
}

将sync方法转换为与C#异步

public class JobRunner
{
    public async Task<string> Run(bool fireAndForget)
    {
        await ShortMethodIAlwaysWantToWait();
        string jobId = Guid.NewGuid().ToString("N");
        if (fireAndForget)
            HostingEnvironment.QueueBackgroundWorkItem((token) => LongMethodICouldWantToWaitOrNot(jobId));
        else
            await LongMethodICouldWantToWaitOrNot(jobId);
        return jobId;
    }
    private async Task LongMethodICouldWantToWaitOrNot(string jobId)
    {
        await Task.Delay(5000);
    }
    private async Task ShortMethodIAlwaysWantToWait()
    {
        await Task.Delay(2000);
    }
}

在.Net 4.5.2之前，请注意AspNet上的后台任务，您不应该"激发并忘记"异步方法，因为线程可以在任务结束前中止。从4.5.2开始，您可以使用HostingEnvironment.QueueBackgroundWorkItem

        public async Task<string> Run()
        {
            ShortMethodIAlwaysWantToWait();
            string jobId = Guid.NewGuid().ToString("N");
            if (iwantToAWait) {
                var task = Task.Run(() => LongMethodICouldWantToWaitOrNot(jobId));
                await task;
            }
            else
               LongMethodICouldWantToWaitOrNot(jobId)
            return jobId;
        }

通过这种方式，Task要么被等待：控制被返回给调用者，然后调用者可以决定是等待还是等待，要么Task在阻塞当前线程时被等待。

您可能希望将操作更改为async，并将调用更新为：

string jobId = await runner.Run();

或者您也可以使用Task<string> 进行同样的操作

var task = runner.Run();
task.Wait();
string jobId = task.Result;

编辑：重要的是LongMethodICouldWantToWaitOrNot是否正在执行CPU绑定操作，在这种情况下，使用Task.Run运行它是有意义的，或者该方法的"缓慢"是否是由I/O操作引起的，在这种情形下，您应该将其设为async，我看不出有任何理由同步运行它。

相关文章：