Цепочка задач в csharp с обработчиком успеха и ошибки

Здесь было сказано много всего, поэтому я отвечаю только на последний раздел «Проблема»:

Customer.GetCustomersAsync(request)
    .ContinueWith(_ => { Debug.WriteLine("not executing"); Fault(request); }, TaskContinuationOptions.OnlyOnFaulted)
    .ContinueWith(_ => { Debug.WriteLine("not executing either"); Result(request); }, TaskContinuationOptions.OnlyOnRanToCompletion);

Проблема здесь (и в исходном примере тоже) в том, что происходит следующее:

1. Вы продолжаете GetCustomersAsync с продолжением "только при ошибке".
2. Затем вы продолжаете это продолжение, а не GetCustomersAsync, со следующим продолжением, которое может выполняться только по завершении.

В результате оба продолжения могут выполняться только при сбое GetCustomersAsync. Исправить:

var request = Customer.GetCustomersAsync(request);
request.ContinueWith(_ => { Debug.WriteLine("not executing"); Fault(request); }, TaskContinuationOptions.OnlyOnFaulted);
request.ContinueWith(_ => { Debug.WriteLine("not executing either"); Result(request); }, TaskContinuationOptions.OnlyOnRanToCompletion);

Обратите внимание, что даже если вы не можете изменить сигнатуру какого-то метода и он обязательно должен возвращать void, вы все равно можете пометить его как асинхронный:

public async void DoSomethingAsync(MyRequest request)
{
     try {
         await Customer.GetCustomersAsync(request);
         Result(request);      
     }
     catch (Exception ex) {
         Fault(request);
     }
}

Есть несколько проблем с этим кодом:

Delegate.Job1(request)
    .ContinueWith(Delegate.Job2)
    .ContinueWith(Fault, TaskContinuationOptions.OnlyOnFaulted)
    .ContinueWith(Result);

Прежде всего, вы продолжаете выполнение с Delegate.Job2, даже если Delegate.Job1 не удалось. Итак, вам нужно значение OnlyOnRanToCompletion здесь. Аналогично продолжению Result, вы продолжаете во всех случаях, поэтому задача с ошибкой все равно проходит по цепочке и, как вы уже видите, находится в состоянии Faulted с null результатом.

Итак, ваш код, если вы не можете использовать на этом уровне await, может быть таким (также, как заявил @Evk, вам пришлось добавить обработку исключений ко всему вашему коду, что действительно уродливо):

Delegate.Job1(request)
    .ContinueWith(Delegate.Job2, TaskContinuationOptions.OnlyOnRanToCompletion)
    .ContinueWith(Fault, TaskContinuationOptions.OnlyOnFaulted)
    .ContinueWith(Result, TaskContinuationOptions.OnlyOnRanToCompletion)
    .ContinueWith(Fault, TaskContinuationOptions.OnlyOnFaulted);

Однако у вас все еще есть возможность использовать ключевое слово await внутри вашего метода, а затем использовать лямбда-выражение для его синхронного запуска, если это вам подходит:

public async Task DoSomethingAsync(MyRequest request)
{
    try
    {
         request.result1 = await delegateInstance.Job1(request);
         request.result2 = await delegateInstance.Job2(request);
         Console.Writeline(request.result1 + " " + request.result2);
         return result;
     }
     catch(Exception e)
     {

     }
}

public void ICannotBeAsync()
{
    var task = Task.Run(() => caller.DoSomethingAsync(request);
    // calling the .Result property will block current thread
    Console.WriteLine(task.Result);
}

Обработку исключений можно выполнять на любом уровне, так что вам решать, где ее вводить. Если во время выполнения что-то пойдет не так, свойство Result вызовет ошибку < a href="https://msdn.microsoft.com/en-us/library/system.aggregateexception.aspx" rel="nofollow noreferrer">AggregateException в качестве оболочки для внутренних исключений, произошедших во время вызова. Также вы можете использовать метод Wait для задачи, завернутый в предложение try/catch, после чего проверять состояние задачи и обрабатывать ее по мере необходимости (у нее есть IsFaulted, IsCompleted, IsCanceled логические свойства).

Кроме того, настоятельно рекомендуется использовать некоторую логику отмены для ваших задач, ориентированных на задачи, чтобы иметь возможность отменить ненужную работу. Вы можете начать с этой статьи MSDN.

Обновление, основанное на ваших других вопросах:

Если вы все еще хотите использовать ContinueWith вместо await и хотите изменить сигнатуры методов Job1, Job2, вы должны изменить свой код следующим образом:

Delegate.Job1(request)
    .ContinueWith(_ => Delegate.Job2(request), TaskContinuationOptions.OnlyOnRanToCompletion)
    .ContinueWith(Result, TaskContinuationOptions.OnlyOnRanToCompletion)
    .ContinueWith(Fault, TaskContinuationOptions.OnlyOnFaulted);

Причина этого в том, что метод ContinueWith принимает Func<Task, Task>, потому что вам, как правило, нужно проверять статус задачи и/или ее результат.

Что касается вопроса о том, чтобы не блокировать звонящего, вы можете попробовать TaskCompletionSource<TResult> класс, что-то вроде этого:

public void ICannotBeAsync()
{
    var source = new TaskCompletionSource<TResult>();
    var task = Task.Run(() => caller.DoSomethingAsync(request, source);
    while (!source.IsCompleted && !source.IsFaulted)
    {
        // yeild the execution to other threads for now, while the result isn't available
        Thread.Yeild();
    }
}

public async Task DoSomethingAsync(MyRequest request, TaskCompletionSource<TResult> source)
{
     request.result1 = await delegateInstance.Job1(request);
     request.result2 = await delegateInstance.Job2(request);
     Console.Writeline(request.result1 + " " + request.result2);
     source.SetResult(result);
}