タスクにしかアクセスできない場合、リフレクションを使用して、またはその他の方法で継続タスクを作成して返すにはどうすればよいですか?
継続中の例外を元の呼び出し元に戻す方法が必要です。私の知る限り、これは元のタスクの代わりに継続タスクを返すことによってのみ行うことができます。タスクの結果の型がわからないため、適切な継続タスクを作成できないという問題があります。
編集:署名の種類を変更できません。Task< TResult > オブジェクトを返す多くのインターフェイスがあり、クライアントが Task< Object > の結果を取得することを期待できません。これらのインターフェイスは WCF コントラクトです。「コア」ロジックメソッドが完了した後に追加の検証ロジックを実行し、必要に応じて例外をスローしたいと考えています。この例外はクライアントに戻る必要がありますが、継続タスクをまだ返していないため、現在は戻りません。また、postsharp アスペクトを適用し、OnExit() オーバーライドを使用しているため、事前にタイプがわかりません。これにより、Task であることがわかっている戻り値にアクセスできますが、Task オブジェクトの任意の数にすることができます。 TResult は実行時にのみ認識されます。
using System;
using System.Threading.Tasks;
namespace TaskContinueWith
{
internal class Program
{
private static void Main(string[] args)
{
try
{
Task<string> myTask = Interceptor();
myTask.Wait();
}
catch (Exception ex)
{
Console.WriteLine(ex);
}
Console.ReadLine();
}
private static Task<string> Interceptor()
{
Task<string> task = CoreLogic(); //Ignore
Task unknownReturnType = task; //This is what I have access to. A Task object which can be one of numerous Task<TResult> types only known at runtime.
Task continuation = unknownReturnType.ContinueWith(
t =>
{
if(someCondition)
{
throw new Exception("Error");
}
return t.Result; //This obviously does not work since we don't know the result.
});
return continuation;
}
private static async Task<string> CoreLogic()
{
return "test";
}
}
}
問題を表現する別の方法。
- DoExtraValidation() の内容のみを変更できます。
- DoExtraValidation() の署名を変更してジェネリックを使用することはできません。
DoExtraValidation を変更して、任意の Task< TResult > 戻り値の型で機能するようにするにはどうすればよいですか?
using System;
using System.Threading.Tasks;
namespace TaskContinueWith
{
interface IServiceContract
{
Task<string> DoWork();
}
public class Servce : IServiceContract
{
public Task<string> DoWork()
{
var task = Task.FromResult("Hello");
return (Task<string>) DoExtraValidation(task);
}
private static Task DoExtraValidation(Task task)
{
Task returnTask = null;
if (task.GetType() == typeof(Task<string>))
{
var knownType = task as Task<string>;
returnTask = task.ContinueWith(
t =>
{
if(new Random().Next(100) > 50)
{
throw new Exception("Error");
}
return knownType.Result;
});
}
return returnTask;
}
}
internal class Program
{
private static void Main(string[] args)
{
try
{
IServiceContract myService = new Servce();
Task<string> myTask = myService.DoWork();
myTask.Wait();
}
catch (Exception ex)
{
Console.WriteLine(ex);
}
Console.ReadLine();
}
}
}