Почему второе задание ожидает завершения первого? - PullRequest
Новая
       20

Почему второе задание ожидает завершения первого?

0 голосов
/ 29 марта 2019

Я пишу приложение, в котором у меня есть класс Rechnungsleser с двумя методами и некоторыми полями. Поля: 

invoices = new BlockingCollection<Invoice>(new ConcurrentQueue<Invoice>());
// Total number of invoices in the XML
invoicesToProcess = XDocument.Load(sourceFile).Root.Elements().Count();
// Number of invoices consumed
invoicesProecessed = 0;


public void ReadRechnungslauf() (below)
using (XmlReader rechnungsreader = XmlReader.Create(sourceFile))
{
    // Iterate over whole file
    while (!rechnungsreader.EOF)
    {
        if (someCondition)
        {
            XElement rechnung = XNode.ReadFrom(rechnungsreader) as XElement;
            // Some minor change
            Helper.RemoveAllNamespaces(rechnung);

            if (rechnung != null)
            {
                try
                {
                    // Decent change, takes XElement, reads and changes some Elements, return object of type Invoice
                    invoices.Add(CreateRechnung(rechnung, possibleOverlays));
                }
                catch (Exception e)
                {
                    Log(e)
                    throw;
                }

            }
        }
        else
        {
            rechnungsreader.Read();
        }
    }
}

public void ProcessRechnungslauf()
{  
    Rechnung currentRechnung;
    // Check that all invoices are processed
    while (invoicesToProcess != invoicesProecessed)
    {
         // Take next enqueued item
         currentRechnung = rechnungen.Take();
         if (currentRechnung.PrintMode.Equals("Online"))
         {
              // Very computing heavy method
              printer.PrintRechnung(currentRechnung);
         }
         invoicesProcessed++;
     }
}

Я инициализирую оба метода следующим образом: 

using (Rechnungsleser reader = new Rechnungsleser()
{
   Task readingTask = Task.Factory.StartNew(() =>
   {
       reader.ReadRechnungslauf();
   });
   Task processingTask = Task.Factory.StartNew(() =>
   {
       reader.ProcessRechnungslauf();
   });
   Task.WaitAll(readingTask, processingTask);
}

Когда я проверяю журнал, он сначала читает все счета и помещает их в очередь, а затем начинает их обрабатывать. Как я могу обеспечить параллелизм? Только потому, что ProcessRechnungslauf() требуется гораздо больше производительности, чем ReadRechnungslauf()?
Должен ли я использовать Threads или TaskParallelLibrary? Почему?
Насколько я понимаю, Task берет доступный Thread из Threadpool и выполняет его. Я не понимаю, почему эти 2 задачи не должны работать вместе.

...