Параллельные задачи. Запускайте параллельные потоки, но не ждите завершения других задач и получайте последние данные изC#

Место общения программистов C#
Ответить Пред. темаСлед. тема
Anonymous
 Параллельные задачи. Запускайте параллельные потоки, но не ждите завершения других задач и получайте последние данные из

Сообщение Anonymous »

Я использую библиотеку задач для параллельного выполнения нескольких задач и использую приведенный ниже код для ожидания завершения других задач.

Код: Выделить всё

Parallel.ForEach(DatafromDB,
item => { DownloadSSR(mediator, sourcePath, item,stoppingToken).Wait();
});
Используя это, я чувствовал, что на самом деле я не делаю параллельно, потому что, например, для 3 задач, Task1, Task2 и Task3.
Task1 говорит занимает 15 минут, а другие задачи - 1 минуту соответственно, в этом случае мы ждем завершения всех задач.
Чтобы добиться этого, у меня есть еще один вариант - "Макс.степеньпараллелизма"

Код: Выделить всё

Parallel.ForEach(DatafromDB,
new ParallelOptions { MaxDegreeOfParallelism = 3},
item => { DownloadSSR(mediator, sourcePath, item,stoppingToken).Wait();
});
Теперь задачи выполняются параллельно, но данные из БД берутся только в первый раз.
Например: если есть 3 данных, из которых я получил БД, тогда тот же источник данных используется для параллельного выполнения задач.
Вот чего я хочу достичь -
  • Я хочу запускать задачи параллельно.
  • Мне не нужно ждать завершения других задач
  • Если одна задача выполнена, назначьте ей другую работу (перейдите в базу данных, получите данные и назначьте новую работу)


Подробнее здесь: https://stackoverflow.com/questions/786 ... o-complete
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «C#»