したがって、 ServiceController.WaitForStatusはブロッキング コールです。タスク/非同期の方法で行うにはどうすればよいですか?
1836 次
1 に答える
17
コードServiceController.WaitForStatus
は次のとおりです。
public void WaitForStatus(ServiceControllerStatus desiredStatus, TimeSpan timeout)
{
DateTime utcNow = DateTime.UtcNow;
this.Refresh();
while (this.Status != desiredStatus)
{
if (DateTime.UtcNow - utcNow > timeout)
{
throw new TimeoutException(Res.GetString("Timeout"));
}
Thread.Sleep(250);
this.Refresh();
}
}
これは、次を使用してタスク ベースの API に変換できます。
public static class ServiceControllerExtensions
{
public static async Task WaitForStatusAsync(this ServiceController controller, ServiceControllerStatus desiredStatus, TimeSpan timeout)
{
var utcNow = DateTime.UtcNow;
controller.Refresh();
while (controller.Status != desiredStatus)
{
if (DateTime.UtcNow - utcNow > timeout)
{
throw new TimeoutException($"Failed to wait for '{controller.ServiceName}' to change status to '{desiredStatus}'.");
}
await Task.Delay(250)
.ConfigureAwait(false);
controller.Refresh();
}
}
}
またはサポート付きCancellationToken
public static class ServiceControllerExtensions
{
public static async Task WaitForStatusAsync(this ServiceController controller, ServiceControllerStatus desiredStatus, TimeSpan timeout, CancellationToken cancellationToken)
{
var utcNow = DateTime.UtcNow;
controller.Refresh();
while (controller.Status != desiredStatus)
{
if (DateTime.UtcNow - utcNow > timeout)
{
throw new TimeoutException($"Failed to wait for '{controller.ServiceName}' to change status to '{desiredStatus}'.");
}
await Task.Delay(250, cancellationToken)
.ConfigureAwait(false);
controller.Refresh();
}
}
}
于 2016-07-07T01:15:38.083 に答える