Асинхронные задачи занимают слишком много времени

Question

Привет, ребята, я пытался сделать асинхронный подход к моей функции, связанной с процессором, которые вычисляют некоторые совокупные функции. Дело в том, что есть какой-то тупик (я полагаю), потому что время вычисления слишком отличается. Я reallz новичок в этой задаче Параллельный мир, я также читаю статьи Stephem Cleary, но я все еще не уверен во всем аспекте этого асинхронного подхода. Мой код:

private static void Main(string[] args) 
{ 
    PIServer server = ConnectToDefaultPIServer(); 
    AFTimeRange timeRange = new AFTimeRange("1/1/2012", "6/30/2012"); 
    Program p = new Program(); 
    for (int i = 0; i < 10; i++) 
    { 
     p.TestAsynchronousCall(server, timeRange); 
     //p.TestAsynchronousCall(server, timeRange).Wait();-same results 
    } 
    Console.WriteLine("Main check-disconnected done"); 
    Console.ReadKey(); 
} 

private async Task TestAsynchronousCall(PIServer server, AFTimeRange timeRange) 
{ 
    AsyncClass asyn; 
    for (int i = 0; i < 1; i++) 
    { 
     asyn = new AsyncClass(); 
     await asyn.DoAsyncTask(server, timeRange); 
     //asyn.DoAsyncTask(server, timeRange);-same results 
    } 
} 

public async Task DoAsyncTask(PIServer server, AFTimeRange timeRange) 
{ 
     var timeRanges = DivideTheTimeRange(timeRange); 
     Task<Dictionary<PIPoint, AFValues>>[] tasksArray = new Task<Dictionary<PIPoint, AFValues>>[2]; 

     tasksArray[0] = (Task.Run(() => CalculationClass.AverageValueOfTagPerDay(server, timeRanges[0]))); 
     // tasksArray[1] = tasksArray[0].ContinueWith((x) => CalculationClass.AverageValueOfTagPerDay(server, timeRanges[1])); 
     tasksArray[1] = (Task.Run(() => CalculationClass.AverageValueOfTagPerDay(server, timeRanges[1]))); 


     Task.WaitAll(tasksArray); 
     //await Task.WhenAll(tasksArray); -same results 
     for (int i = 0; i < tasksArray.Length; i++) 
     { 
      Program.Show(tasksArray[i].Result); 
     } 
} 

измеряю время Повсеместно Секундомер в функциях AverageValueOfTagPerDay. Эта функция синхронна (это проблема?). Каждая задача занимает 12 секунд. Но когда я раскомментировал строку и использовал метод ContinueWith(), эти Задачи занимают 5-6 секунд каждый (что желательно). Как это возможно? Более странно то, что когда я устанавливаю цикл for в Main() на 10, иногда это занимает 5 секунд, а также когда я использую ContinueWith(). Поэтому я предполагаю, что где-то тупик, но я не могу это найти. Извините за английский, у меня все еще проблема, создающая хорошие обратные отсчеты, когда я пытаюсь объяснить некоторые трудности. Приветствие UPDATE я удалил попробовать, который является устаревшим для большей ясности

Answer 1

Привет ребят Я пытаюсь сделать асинхронный подход к моему CPU переплета функции, вычислить некоторые агрегатные функции.

«Асинхронные» и «связанные с процессором» не являются терминами, которые объединяются. Если у вас есть процесс с привязкой к процессору, вы должны использовать параллельные технологии (Parallel, параллельный LINQ, поток данных TPL).

Я новичок в этой задаче Параллельный мир, я также читаю статьи Stephem Cleary, но я все еще не уверен во всем аспекте этого асинхронного подхода.

Возможно, потому что я не рассматриваю параллельные технологии в любых моих статьях или сообщениях в блоге. :) Я их покрываю в своей книге, но не в Интернете. В моей онлайн-работе основное внимание уделяется асинхронности, которая идеально подходит для операций на основе ввода-вывода.

Чтобы решить проблему, вы должны использовать параллельный подход:

public Dictionary<PIPoint, AFValues>[] DoTask(PIServer server, AFTimeRange timeRange) 
{ 
    var timeRanges = DivideTheTimeRange(timeRange); 
    var result = timeRanges.AsParallel().AsOrdered(). 
     Select(range => CalculationClass.AverageValueOfTagPerDay(server, range)). 
     ToArray(); 
    return result; 
} 

Конечно, этот подход предполагает, что PIServer является поточно. Он также предполагает, что класс ввода-вывода не выполняется в/в; если есть, то поток данных TPL может быть лучшим выбором, чем Parallel LINQ.

Если вы планируете использовать этот код в приложении интерфейса и не хотите, чтобы блокировать поток пользовательского интерфейса, то вы можете вызов код асинхронно, как это:

var results = await Task.Run(() => DoTask(server, timeRange)); 
foreach (var result in results) 
    Program.Show(result);