1

Есть WinForms клиент, функция которого обрабатывать файлы из определенной папки пользователя, шифровать, запаковывать их определенным образом и отправлять полученный пакет на wcf сервис. Этот клиент уже был написан, у меня задача его ускорить.


Вот мои мысли и попытки:

  1. Пул Task-ов. Его архитектура построена на пуле Task-ов. То есть документы на обработку складываются в очередь. Затем ранее запущенный Task, внутри которого цикл while(true), следит за этой очередью - берет первый документ, ищет или ждет для него свободный Task из массива пула тасков и дает таску задание:

    TasksPool[index] = Task.Factory.StartNew(() => document.Work(), _cancelWork);

В методе происходил метод отправки документа на сервис:

wcfServiceClient.SendDocument(packet);

У меня возникли в голове такие мысли: когда Task доходит до отправки документа на сервис, и происходит отправка, он тормозит процесс(процесс с этим таском просто зависает и ждет завершения отправки) или как-то сам по умному уходит в ожидание, а его процесс подхватывает в это время работу другого таска? А также возникла мысль что зачем нужно использовать какой-то пул потоков, когда есть готовые средства распараллеливания типа Parallel?

  1. Попытка написать с Parallel.ForEach.

    Parallel.ForEach(files, file => new Document(wcfClient, file).Work())

Просто скажу что лучше не стало, то есть например пул задач для 3-х тасков из 1-го пункта оказался быстрее, чему я очень удивлен. Есть предположение что затык в wcf клиенте...

  1. async await

    class Document { public async Task<bool> Work() { var sendDocumentResult = await _photonServiceClient.SendDocumentAsync(edtPacket); return sendDocumentResult.Result; } }

    var tasks = files.Select(x => new Document(wcfClient, x).Work()); await Task.WhenAll(tasks);

Думал что это решит проблему и процесс не будет простаивать при отправке документа - на деле также никаких преимуществ не дало, работает на уровне 2-го пункта. И теперь я немного в смятении - получается простоев при отправке пакета на сервис не было, уже самый первый вариант работал как нужно? И если 1-й вариант работает быстрее остальных, то значит дело в wcf клиенте, в идеале нужно каждый instance на каждый поток? Но как это соорудить если мы работаем с тасками и не знаем в каком потоке мы фактически выполняемся и сколько потоков будет задействовано?

13
  • в третьем случае нужно избавится от .Result; - это превращает метод в синхронный. и второе: ты можешь создать столько тасков сколько захочешь. если задача ожидает пакетов от сети (i/o bound) - она ресурсов не ест. третье: не понял как ты следил за тасками в цикле? - это buisy wait?
    – dgzargo
    19 июн 2019 в 18:49
  • @dgzargo он там ожидал завершения таска перед тем, как result вызвать
    – tym32167
    19 июн 2019 в 18:51
  • вот пример асинхронного парсера. Но имейте ввиду, что если у вас большая часть времени тратится на вызов сервиса, то хоть как изголяйся, вызов сервиса с клиента не ускорить
    – tym32167
    19 июн 2019 в 18:52
  • @tym32167 именно! и метод стал синхронный!
    – dgzargo
    19 июн 2019 в 18:52
  • @dgzargo не стал, если к моменту вызова result таска уже завершилась
    – tym32167
    19 июн 2019 в 18:53

0

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Посмотрите другие вопросы с метками или задайте свой вопрос.