Создать хорошую задачу холода

Question

У меня есть метод async после завершения которого я хочу запустить другой метод. Это отлично работает, если я просто вызываю метод и добавляю .ContinueWith()

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

Я хотел бы построить задачу, попытаться добавить его, а затем запустить задачу

Тем не менее, кажется, что Task.Start() немедленно завершает задание, вызывающее действие продолжать работать и все ждет .. не ждать.

может кто-нибудь объяснить, почему это происходит, и правильный путь для достижения моей цели?

namespace UnitTestProject2 
{ 
    [TestClass] 
    public class taskProblem 
    { 
     [TestMethod] 
     public void Test() 
     { 
      CancellationTokenSource cancel = new CancellationTokenSource(); 
      ConcurrentDictionary<Guid, Task> tasks = new ConcurrentDictionary<Guid,Task>(); 
      Guid id = Guid.NewGuid(); 
      Task t = new Task(async() => await Get(), cancel.Token); 
      t.ContinueWith(Complete); 
      if (tasks.TryAdd(id, t)) 
      { 
       t.Start(); 
      } 
      else 
      { 
       //another thread is stopping stuff dont start new tasks 
      } 

      t.Wait(); //expected to wait for the get function to complete 
      Console.WriteLine("end test"); 
     } 

     public async Task Get() 
     { 
      Console.WriteLine("start task"); 
      await Task.Delay(10000); 
      Console.WriteLine("end task"); 
     } 

     public void Complete(Task t) 
     { 
      Console.WriteLine("Complete"); 
     } 
    } 
} 

выход:

start task 
end test 
Complete 

ожидается выход:

start task 
end task 
Complete 
end test 

Update: Оказывается, нет никакого способа, чтобы создать новую задачу, которая не будет немедленно начать или полностью немедленно на Task.Start?

Answer 1

Ваш делегат не имеет асинхронности. async void-methods - это огонь и забудьте.

См первую точку Резюме Шаблоны и антишаблоны: http://rarcher.azurewebsites.net/Post/PostContent/31

Может быть, вы можете сделать что-то подобное:

[TestFixture] 
public class FIXTURENAMETests { 
    [Test] 
    public async Task NAME() { 
    var tcs = new TaskCompletionSource<bool>(); 
    Task t = LongRunningStuff(tcs); 

    if (CanInsertInDictionary(t)) { 
     tcs.SetResult(true); 
    } else { 
     tcs.SetException(new Exception()); 
    } 

    Trace.WriteLine("waiting for end"); 

    try { 
     await t; 
    } 
    catch (Exception exception) { 
     Trace.WriteLine(exception); 
    } 

    Trace.WriteLine("end all"); 
    } 

    private bool CanInsertInDictionary(Task task) { 
    return true; 
    } 

    private async Task LongRunningStuff(TaskCompletionSource<bool> tcs) { 
    Trace.WriteLine("start"); 
    try { 
     await tcs.Task; 
    } 
    catch (Exception) { 
     return; 
    } 
    Trace.WriteLine("do long running stuff"); 
    await Task.Delay(10000); 
    Trace.WriteLine("end"); 
    } 
} 

Answer 2

Во-первых, ContinueWith будет возвращать новый Task, вы хотите, чтобы ждать, пока метод Complete завершается, но вы ожидаете первой задачи t.

Таким образом, для вывода Complete перед end test, вы должны ждать на второй задачи:

Task t = new Task(async() => await Get(), cancel.Token); 

// NOTE: t2 is a new Task returned from ContinueWith 
Task t2 = t.ContinueWith(Complete); 

if (tasks.TryAdd(id, t)) 
{ 
    t.Start(); 
} 
else 
{ 
} 

// NOTE: Waiting on t2, NOT t 
t2.Wait(); 

Console.WriteLine("end test"); 

Теперь выход будет:

start task 
Complete 
end test 
end task 

Ладно, это еще не ожидаемый результат , end task следует напечатать до Complete. Это связано с тем, что ваше асинхронное действие не является ожидаемым: How to await on async delegate

Не знаю, правильно ли я понял ваши требования. Если это мне, я мог бы сделать это следующим образом:

Добавить новый опорный класс:

public class TaskEntry 
{ 
    public Task Task { get; set; } 
} 

Затем изменить свой код:

Guid id = Guid.NewGuid(); 

Task task = null; 
var entry = new TaskEntry(); 
if (tasks.TryAdd(id, entry)) 
{ 
    entry.Task = Get(); 

    // Notice this line of code: 
    task = entry.Task.ContinueWith(Complete); 
} 

if (task != null) 
{ 
    task.Wait(); 
} 

Console.WriteLine("end test"); 

Здесь я предполагаю, что TaskEntry не будет изменен другими потоками.