(популярный бренд карри, если кто не знает)

точнее так, почему это не должно работать

thread::spawn:: новый системный тред сделает?

до такого варианта никто из комитетчиков не додумался

если я верно понимаю, если ты заспавнишь в core 100500 потоков, то все будут ждать твоего

а после 100-го сообщение будут делать это вечно

если только r.for_each не предоставляет правильный Poll трейт

ну хоть не java curry

Compared to the spicy and curry-like cuisine of Sumatra that is heavily influenced by Indian cuisine, Javanese cuisine is most notably Chinese and European with a some local touch.

thread::spawn:: новый системный тред сделает?

Да

если я верно понимаю, если ты заспавнишь в core 100500 потоков, то все будут ждать твоего

Да

а у стрима есть Poll

а после 100-го сообщение будут делать это вечно

?

https://docs.rs/futures/0.1.7/futures/sync/mpsc/struct.Receiver.html

хм.. теперь мне интересно как это работает

хм.. теперь мне интересно как это работает

Что именно

а for_each создает ForEach у которого есть Poll

Форич это способ сделать из стрима фьючу

cat /proc/sys/kernel/threads-max  ✔️  290  17:19:03 62496 ))))))))

Ulimit нельзя поднять?

если я верно понимаю, если ты заспавнишь в core 100500 потоков, то все будут ждать твоего

В общем, при схеме mpsc, если твой один поток не успевает хендлить события, то ничего не поделаешь, тебе наверное нужен mpmc

@c_vld а там round robin или по очереди все?

@c_vld а там round robin или по очереди все?

В mpmc? Зависит от реализации

В mpsc по очереди обычно

core

core

Кор это всего лишь reactor - выполняющий модуль

https://crates.io/crates/multiqueue такое с ходу нашел

Кросбим?

https://crates.io/crates/multiqueue такое с ходу нашел

Если правильно понял он броадкастит одно сообщение, это не совсем нужное

Кор это всего лишь reactor - выполняющий модуль

ну как я понимаю в core ты можешь делать spawn и он будет переключаться между ними

Да, в кросбим поидее такое быть может

ну как я понимаю в core ты можешь делать spawn и он будет переключаться между ними

Нет, в кор ты пихаешь одну фьючю

Хотя у кора есть хендл в котором есть спавн

Выполняются они по notify поидее, скорее всего без каких-то хитрых раунд Робин, просто нотифай добавит фьючу в конец очереди. По крайней мере так было б логично и максимально просто

хм.. я с handle.spawn(..) попутал похоже

оно же позволяет много вещей запускать?

let server = connections.for_each(move |(socket, _peer_addr)| { let (writer, reader) = socket.framed(LineCodec).split(); let service = s.new_service()?; let responses = reader.and_then(move |req| service.call(req)); let server = writer.send_all(responses) .then(|_| Ok(())); handle.spawn(server); Ok(()) });

из мануала

Позволит

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

вот я думал, что если у тебя такое, то тогда r.for_each(.. из кода, из заблочит

но я был не прав

как же все таки грустно все с токио в расте

вроде бы доки есть

а вроде бы и нихуя нет вовсе

ебучий ад

++

особенно если хочешь понять как внутри оно работает

а там прикольные штуки есть

интересный язык чтобы его знать

я целый exercism прошёл на расте

!!!

в общем иногда хочется знать какой-нить язык поближе к железу в запасе

а я чего-то забил

а я тоже забил проверять

до туда далеко лезть

там дальше норм?

так себе

в начале какая-то скукота

ну всякие магины тюринга, смешные калькуляторы minesweeper-ы

из интересного

но так 50-100 строк кода максимум

язык после этого знать не будешьь

у меня есть одна задача куда его можно, но она не нужна

и уже сть решения на го

обоснуй

можно менее виртуозно научиться пользоваться

ну так-то да, ускоряет обучение и внимательность

если мильёны

Мильены и программисты если и связаны, то только через менеджера. Если что и ускоряет обучение, так это подзатыльники от проджект менеджера, а не гипотетические мильоны барина.

примеры некоторых трейдинг фирм говорят что это не точно

например Tsuru Capitals

Объявляю их еритиками, они продались за бабки, эх а могли бы стмы за доширак программировать

Так ничего в жизни и не добьются!

не то на чем они пишут для стм не годно

Полезный плагин Android Studio для серьёзных разработчиков https://habrahabr.ru/post/343392/

Ну наконец-то

Так не хватало

схоронил

О, норм

Казалось бы, при чём тут Android Studio

точнее так, почему это не должно работать

Был не прав. В документации (https://docs.rs/futures/0.1.17/futures/future/trait.Future.html#method.wait) говорится: This method should only be called when it's guaranteed that the blocking work associated with this future will be completed by another thread. Как оказалось, это применимо к futures::sync::mpsc. Там Sender прокидывает Task в Receiver через эту очередь: https://github.com/alexcrichton/futures-rs/blob/master/src/sync/mpsc/mod.rs#L251). В документации к futures::sync::mpsc , однако, ничего об этом не сказано. Будем знать.