Есть ли причина, по которой List <Task> не всегда работает параллельно?

Question

Есть ли причина, по которой List <Task> не всегда работает параллельно?

2

Когда мне нужна параллельная обработка, я обычно делаю это так:

static void Main(string[] args)
{
    var tasks = new List<Task>();
    var toProcess = new List<string>{"dog", "cat", "whale", "etc"};
    toProcess.ForEach(s => tasks.Add(CanRunAsync(s)));
    Task.WaitAll(tasks.ToArray());
}

private static async Task CanRunAsync(string item)
{
    // simulate some work
    await Task.Delay(10000);
}

У меня были случаи, когда это не обрабатывало элементы параллельно и приходилось использовать Task.Run чтобы заставить его работать в разных потоках.

Что мне не хватает?

Alex 13 март 2019, в 15:03

Источник

3

Task не является Thread . На самом деле Task может работать в exat же Thread . Посмотрите на stackoverflow.com/questions/34375696/…
HimBromBeere 13 март 2019, в 14:03
0

Список задач не запускается вообще. Это просто список объектов Task, которые на самом деле могут быть холодными. Что делает CanRun ? Он запускает какие-либо задачи или возвращает холодные задачи?
Panagiotis Kanavos 13 март 2019, в 14:05
1

« Что мне не хватает? » То же самое, что нам не хватает, я думаю: контекст вашего вопроса, который объясняет, что на самом деле делают ваши задачи, и что этот метод CanRun делает для установки и запуска задач ...
user2819245 13 март 2019, в 14:06
0

Можете ли вы показать метод CanRun ?
Yacoub Massad 13 март 2019, в 14:06
1

Если вы хотите обрабатывать много данных параллельно, вам следует использовать специально созданные API-интерфейсы, Parallel.ForEach или PLINQ. Parallel.ForEach(toProcess,processingFunction) будет обрабатывать все данные параллельно. Так что toProcess.AsParallel().Select(str=>......).ToArray()
Panagiotis Kanavos 13 март 2019, в 14:06
0

(Кроме того, это может быть более кратко написано Task.WaitAll(toProcess.Select(CanRun)) )
canton7 13 март 2019, в 14:07
1

had to use Task.Run вы всегда должны использовать это, или TaskFactory.StartNew, если вы хотите создать горячую задачу, то есть ту, которая выполняет свою функцию
Panagiotis Kanavos 13 март 2019, в 14:08
0

@PanagiotisKanavos Нет, это просто ложь. Фактически, любой метод, который когда-либо возвращает задачу, должен возвращать «горячую» задачу. Любые, которые не почти наверняка сломаны. Task.Run существует для создания задачи, которая выполняет синхронную связанную с процессором операцию в потоке пула потоков. Вот и все. Если это не то, что они пытаются сделать, нет необходимости в Task.Run .
Servy 13 март 2019, в 14:20
0

@servy, и мы еще не знаем, что ОП хочет сделать. Начало очередного раунда придирки никому не поможет.
Panagiotis Kanavos 13 март 2019, в 14:22
1

@PanagiotisKanavos Конечно, мы не знаем, что хочет сделать ОП. Но ваше утверждение просто неверно, независимо от того, что хочет сделать ОП. Вы констатируете ложную информацию о том, что делает Task.Run или как его использовать, вредно, исправляя эти заблуждения , помогая людям.
Servy 13 март 2019, в 14:36
0

@ Сервис Хорошо, вы выиграли, вы правы, как всегда, и комментарии должны быть внизу
Panagiotis Kanavos 13 март 2019, в 14:42
0

@PanagiotisKanavos: задачи всегда возвращаются горячими. Я не совсем уверен , что «холодная» Task была бы , если это не просто уже завершена Task , например, от Task.CompletedTask или Task.FromResult<T> .
Chris Pratt 13 март 2019, в 19:14
0

@ChrisPratt вы найдете МНОГИЕ вопросы с людьми, создающими холодные задачи с new Task() затем начинающими их с .Start() как если бы они были потоками. Это довольно распространенная проблема. Если вы ищете [c#] "new Task(" вы найдете довольно много случаев. Забавно, если вы прочитаете первый комментарий Servy, он согласится. Похоже, что он не согласен с тем, что я не включил полное вступление к Задачи в двухстрочном комментарии о вопросе, исходный код и формулировка которого не дают четкого представления о том, что задание было возвращено, had to use Task.Run to force it to run звучало так, как будто возвращено новое задание.
Panagiotis Kanavos 15 март 2019, в 07:59
0

@ChrisPratt и, конечно, никто не забыл упомянуть TaskCompletionSource, что делает всех неправыми, я думаю
Panagiotis Kanavos 15 март 2019, в 08:04
0

@PanagiotisKanavos Я не согласен с тем, что вы сказали, что Task.Run - это единственный способ создать горячую задачу, которая просто наглядно ложна, и не является подходящим способом получить горячую задачу для множества общих операций. Добавление утверждения о том, что OP должен использовать Task.Run является неправильным, запутанным и вредным, и вообще не добавляет ничего полезного к разговору. Я не критиковал вас за то, что вы не сказали больше, вы просто не должны были публиковать этот комментарий. Это не добавляет ничего полезного, вредно и просто ложно. Ничего не сказать лучше, чем сказать что-то не так и ввести в заблуждение.
Servy 10 апр. 2019, в 13:34

Показать ещё 13 комментариев

Теги:

c#

asp.net-core

.net

parallel-processing

1 ответ

Ещё вопросы

Task не является Thread . На самом деле Task может работать в exat же Thread . Посмотрите на stackoverflow.com/questions/34375696/…
Список задач не запускается вообще. Это просто список объектов Task, которые на самом деле могут быть холодными. Что делает CanRun ? Он запускает какие-либо задачи или возвращает холодные задачи?
« Что мне не хватает? » То же самое, что нам не хватает, я думаю: контекст вашего вопроса, который объясняет, что на самом деле делают ваши задачи, и что этот метод CanRun делает для установки и запуска задач ...
Можете ли вы показать метод CanRun ?
Если вы хотите обрабатывать много данных параллельно, вам следует использовать специально созданные API-интерфейсы, Parallel.ForEach или PLINQ. Parallel.ForEach(toProcess,processingFunction) будет обрабатывать все данные параллельно. Так что toProcess.AsParallel().Select(str=>......).ToArray()
(Кроме того, это может быть более кратко написано Task.WaitAll(toProcess.Select(CanRun)) )
had to use Task.Run вы всегда должны использовать это, или TaskFactory.StartNew, если вы хотите создать горячую задачу, то есть ту, которая выполняет свою функцию
@PanagiotisKanavos Нет, это просто ложь. Фактически, любой метод, который когда-либо возвращает задачу, должен возвращать «горячую» задачу. Любые, которые не почти наверняка сломаны. Task.Run существует для создания задачи, которая выполняет синхронную связанную с процессором операцию в потоке пула потоков. Вот и все. Если это не то, что они пытаются сделать, нет необходимости в Task.Run .
@servy, и мы еще не знаем, что ОП хочет сделать. Начало очередного раунда придирки никому не поможет.
@PanagiotisKanavos Конечно, мы не знаем, что хочет сделать ОП. Но ваше утверждение просто неверно, независимо от того, что хочет сделать ОП. Вы констатируете ложную информацию о том, что делает Task.Run или как его использовать, вредно, исправляя эти заблуждения , помогая людям.
@ Сервис Хорошо, вы выиграли, вы правы, как всегда, и комментарии должны быть внизу
@PanagiotisKanavos: задачи всегда возвращаются горячими. Я не совсем уверен , что «холодная» Task была бы , если это не просто уже завершена Task , например, от Task.CompletedTask или Task.FromResult<T> .
@ChrisPratt вы найдете МНОГИЕ вопросы с людьми, создающими холодные задачи с new Task() затем начинающими их с .Start() как если бы они были потоками. Это довольно распространенная проблема. Если вы ищете [c#] "new Task(" вы найдете довольно много случаев. Забавно, если вы прочитаете первый комментарий Servy, он согласится. Похоже, что он не согласен с тем, что я не включил полное вступление к Задачи в двухстрочном комментарии о вопросе, исходный код и формулировка которого не дают четкого представления о том, что задание было возвращено, had to use Task.Run to force it to run звучало так, как будто возвращено новое задание.
@ChrisPratt и, конечно, никто не забыл упомянуть TaskCompletionSource, что делает всех неправыми, я думаю
@PanagiotisKanavos Я не согласен с тем, что вы сказали, что Task.Run - это единственный способ создать горячую задачу, которая просто наглядно ложна, и не является подходящим способом получить горячую задачу для множества общих операций. Добавление утверждения о том, что OP должен использовать Task.Run является неправильным, запутанным и вредным, и вообще не добавляет ничего полезного к разговору. Я не критиковал вас за то, что вы не сказали больше, вы просто не должны были публиковать этот комментарий. Это не добавляет ничего полезного, вредно и просто ложно. Ничего не сказать лучше, чем сказать что-то не так и ввести в заблуждение.

Marc Gravell · Accepted Answer · 2019-03-13T12-49-00.000Z

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

Примечание: параллелизм может быть выражен в терминах нескольких задач (если вы того пожелаете), но множественные задачи не подразумевают параллелизм.

В вашем случае: все зависит от того, что делает CanRun или нет - а мы этого не знаем. Вероятно, он также должен называться CanRunAsync.

Спасибо за ваш ответ. Итак, вы говорите, что не имеет значения, если я использую Task.Run или Task.Factory.StartNew или просто добавляю асинхронный метод непосредственно в список задач, нет гарантии, что они будут работать в разных потоках?
@ Алекс, нет, я не это говорю; эти вещи связаны с потоками, хотя нет никакой гарантии, сколько из них будет работать параллельно (это зависит от планировщика); Я отвечаю на вопрос в оригинальной форме, когда CanRun был расплывчатым: в общем случае : задача не означает поток.