AH
Типо есть 100к тасок и паралельно выполнять только 500
это кстати не сработает, так как если у тебя на руках есть 100к тасок, то они уже работают.
там типа так
SomeEnum
.AsParallel()
.WithDegreeOfParallelism(...)
...
Size: a a a
2021 March 03
В
Ну вот я заебался на него доку читать, у меня есть ощущение что он порциями берет и если один из 10 меденный то ничего дальше не дижется, хотя может я туплю
В
это кстати не сработает, так как если у тебя на руках есть 100к тасок, то они уже работают.
Ну не запущенны
AH
Ну вот я заебался на него доку читать, у меня есть ощущение что он порциями берет и если один из 10 меденный то ничего дальше не дижется, хотя может я туплю
ты прав, оно с сохранением порядка
AH
Ну не запущенны
давно ты видел незапущенные таски?
AH
Ну вот я заебался на него доку читать, у меня есть ощущение что он порциями берет и если один из 10 меденный то ничего дальше не дижется, хотя может я туплю
там можно .AsUnordered позвать
В
давно ты видел незапущенные таски?
Короче я написал свой костыль в одном месте и мне теперь в другом надо)))
AH
Вилимо надо dataflow или channel заводить
лучше channel
AH
или сразу гопак бери
AH
и вообще отказываюсь дальше обсуждать костыли из сишарпа в фшарп чате
В
и вообще отказываюсь дальше обсуждать костыли из сишарпа в фшарп чате
Тут просто люди с двумя рабочими полушариями
AH
Тут просто люди с двумя рабочими полушариями
понимаю. Но в священном храме Святого Гопака обсуждать как ты там создаешь 100к холодных тасок и костылишь свой тротлер параллелизации - это кощунство
В
понимаю. Но в священном храме Святого Гопака обсуждать как ты там создаешь 100к холодных тасок и костылишь свой тротлер параллелизации - это кощунство
Катсти AsyncSeq работал бы как мне надо?
AH
Катсти AsyncSeq работал бы как мне надо?
/// Iterates over the input sequence and calls the specified asynchronous function for
/// every value. Each action computation is started but not awaited before consuming
/// the next item from the sequence, thereby iterating in parallel with a specified degree of parallelism.
val iterAsyncParallelThrottled : parallelism:int -> action:('T -> Async<unit>) -> source:AsyncSeq<'T> -> Async<unit>
I
Слухайте в шурпе есть аналог Async.Parallel с уровнем паралеллизма ?
это делается через TaskScheduler
VS
Эээ, ну он же, там же параметром уровень параллелизма прокидывается
там же не уровень параллелизма, а количество тредов обрабатывающих)
I
так это одно и тоже
VS
это уже очень давно обсуждали) типа параллельно может стартануть 100 запросов на двух тредах