CẬP NHẬT 5/2017
C# 6 bộ lọc ngoại lệ làm cho catch khoản đơn giản hơn rất nhiều:
private static async Task<T> Retry<T>(Func<T> func, int retryCount)
{
while (true)
{
try
{
var result = await Task.Run(func);
return result;
}
catch when (retryCount-- > 0){}
}
}
và phiên bản đệ quy:
private static async Task<T> Retry<T>(Func<T> func, int retryCount)
{
try
{
var result = await Task.Run(func);
return result;
}
catch when (retryCount-- > 0){}
return await Retry(func, retryCount);
}
ORIGINAL
Có nhiều cách để mã chức năng Thử lại: bạn có thể sử dụng tính năng đệ quy hoặc lặp lại tác vụ. Đã có một discussion trong nhóm Người dùng .NET của Hy Lạp trong khi quay lại các cách khác nhau để thực hiện chính xác điều này.
Nếu bạn đang sử dụng F #, bạn cũng có thể sử dụng cấu trúc Async. Thật không may, bạn không thể sử dụng các cấu trúc async/await ít nhất trong Async CTP, bởi vì mã được tạo ra bởi trình biên dịch không giống như nhiều chờ đợi hoặc có thể rethrows trong các khối catch.
Phiên bản đệ quy có lẽ là cách đơn giản nhất để xây dựng Thử lại trong C#.Các phiên bản sau không sử dụng Unwrap và cho biết thêm một sự chậm trễ bắt buộc trước khi thử lại:
private static Task<T> Retry<T>(Func<T> func, int retryCount, int delay, TaskCompletionSource<T> tcs = null)
{
if (tcs == null)
tcs = new TaskCompletionSource<T>();
Task.Factory.StartNew(func).ContinueWith(_original =>
{
if (_original.IsFaulted)
{
if (retryCount == 0)
tcs.SetException(_original.Exception.InnerExceptions);
else
Task.Factory.StartNewDelayed(delay).ContinueWith(t =>
{
Retry(func, retryCount - 1, delay,tcs);
});
}
else
tcs.SetResult(_original.Result);
});
return tcs.Task;
}
Chức năng StartNewDelayed xuất phát từ ParallelExtensionsExtras mẫu và sử dụng một bộ đếm thời gian để kích hoạt một TaskCompletionSource khi timeout xảy ra.
Chiếc F # phiên bản đơn giản hơn rất nhiều:
let retry (asyncComputation : Async<'T>) (retryCount : int) : Async<'T> =
let rec retry' retryCount =
async {
try
let! result = asyncComputation
return result
with exn ->
if retryCount = 0 then
return raise exn
else
return! retry' (retryCount - 1)
}
retry' retryCount
Unfortunatley, nó là không thể để viết một cái gì đó tương tự như trong C# sử dụng async/chờ đợi từ Async CTP vì trình biên dịch không thích chờ đợi báo cáo bên trong một khối catch. Nỗ lực sau đây cũng không silenty, bởi vì thời gian chạy không thích gặp phải một chờ đợi sau một ngoại lệ:
private static async Task<T> Retry<T>(Func<T> func, int retryCount)
{
while (true)
{
try
{
var result = await TaskEx.Run(func);
return result;
}
catch
{
if (retryCount == 0)
throw;
retryCount--;
}
}
}
Đối với yêu cầu người dùng, bạn có thể sửa đổi Thử lại để gọi một chức năng mà yêu cầu người dùng và trả về một nhiệm vụ thông qua một TaskCompletionSource để kích hoạt các bước tiếp theo khi các câu trả lời của người dùng, ví dụ:
private static Task<bool> AskUser()
{
var tcs = new TaskCompletionSource<bool>();
Task.Factory.StartNew(() =>
{
Console.WriteLine(@"Error Occured, continue? Y\N");
var response = Console.ReadKey();
tcs.SetResult(response.KeyChar=='y');
});
return tcs.Task;
}
private static Task<T> RetryAsk<T>(Func<T> func, int retryCount, TaskCompletionSource<T> tcs = null)
{
if (tcs == null)
tcs = new TaskCompletionSource<T>();
Task.Factory.StartNew(func).ContinueWith(_original =>
{
if (_original.IsFaulted)
{
if (retryCount == 0)
tcs.SetException(_original.Exception.InnerExceptions);
else
AskUser().ContinueWith(t =>
{
if (t.Result)
RetryAsk(func, retryCount - 1, tcs);
});
}
else
tcs.SetResult(_original.Result);
});
return tcs.Task;
}
với tất cả các continuations, bạn có thể thấy tại sao một phiên bản async của Thử lại rất đáng mơ ước.
UPDATE:
Trong Visual Studio 2012 Beta hai phiên bản sau làm việc:
Một phiên bản với một vòng lặp while:
private static async Task<T> Retry<T>(Func<T> func, int retryCount)
{
while (true)
{
try
{
var result = await Task.Run(func);
return result;
}
catch
{
if (retryCount == 0)
throw;
retryCount--;
}
}
}
và một phiên bản đệ quy:
private static async Task<T> Retry<T>(Func<T> func, int retryCount)
{
try
{
var result = await Task.Run(func);
return result;
}
catch
{
if (retryCount == 0)
throw;
}
return await Retry(func, --retryCount);
}
@svick tôi đã không cố gắng để thực hiện chức năng này đó là một nhiệm vụ tương lai sắp tới, trông giống như chúng tôi đã nhận những ý tưởng thú vị đã có, đã đi qua chúng một cách chi tiết và cung cấp cho nó một thử –