170 похожих чатов

Всем привет, можете подсказать, пожалуйста по многопоточности еще один момент.



Если у меня есть массив из 100 строк, и я хочу создать 10 потоков, каждый из которых будет принимать в себя строку из массива.

Как только строка обработалась, в поток поступает следующая строка из массива. Как это можно сделать?

15 ответов

19 просмотров

Parallel.ForEach, можно указать максимальное кол-во потоков

Ченелами Делаешь 10 ченелов воркеров и 1 ченел который раздаёт из массива когда ченелы освободились

Nikolay-Nefedov Автор вопроса
Musa Musaev
Parallel.ForEach, можно указать максимальное кол-в...

И в освободишийся поток автоматом прилетит следующая задача?

Musa Musaev
Parallel.ForEach, можно указать максимальное кол-в...

В случае наличия внутри await всё будет весело.

Dmitriy Bobrovskiy
В случае наличия внутри await всё будет весело.

+ Помню, писал реализацию асинка для енумерабл под это дело.. Ну нахер))

Dmitriy Bobrovskiy
В случае наличия внутри await всё будет весело.

Пример был со строками в массиве, самое простое для этого кейса Parallel.ForEach Другое дело, если есть асинхронщина. Можно использовать Semaphore. Можно использовать те же Channel-ы, как предложил выше Айрат

Igor Ki
+ Помню, писал реализацию асинка для енумерабл под...

Ага. Ну, там вариант либо как гуру сказал через ченнелы, либо через Semaphoreslim

Nikolay-Nefedov Автор вопроса
Ayrat Hudaygulov
Ченелами Делаешь 10 ченелов воркеров и 1 ченел кот...

Слушай, не совсем могу понять, как именно использовать ченелы тут

Nikolay-Nefedov Автор вопроса
Ayrat Hudaygulov
https://gist.github.com/Szer/a8f4ac7921ac4ed4f0a0a...

Ооооо, спасибо большое, Айрат, оч приятно, что заморочился и написал!)

Nikolay Nefedov
Ооооо, спасибо большое, Айрат, оч приятно, что зам...

заметь что ченелы нигде в апи операции не торчат, это сугубо деталь имплементации

Nikolay-Nefedov Автор вопроса

Я вроде весь код понял, но как его переделать под шарп вообще не понял

Nikolay Nefedov
Я вроде весь код понял, но как его переделать под ...

Да в смысле! Один в один же! Я там только в конце использовал фшарпный asyncSeq чтобы воспользоваться IAsyncEnumerable

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта