Телеграмм чат группы rust

Size: a a a

Rust Async

349 membersпожаловаться на группу

2018 August 04

Vladimir in Rust Async

мухожук

предлагаю залететь в джава чат и узнать

в го

вроде STM

STM это же TVar, т.е для разруливания доступа к ресурсу из различных потоков через транзакции
а MVar - это ячейка запись в которую разрешена только если она свободная иначе писатель блокируется; а чтение только если она полна, иначае читатель блорируется, что-то вроде futures::sync::oneshot

источник

14:46пожаловаться #2

Vladimir in Rust Async

Mutex<Option<T>>

наверное, если не одноразовая

источник

14:48пожаловаться #3

λоλторт in Rust Async

Vladimir

Mutex<Option<T>>

наверное, если не одноразовая

такое себе

источник

14:49пожаловаться #4

мухожук in Rust Async

блокирующие каналы, не?

источник

14:55пожаловаться #5

мухожук in Rust Async

crossbeam_channel::bounded(1)

источник

14:55пожаловаться #6

andor0 in Rust Async

размером 1 ячейка? да, тоже похоже на MVar

источник

14:56пожаловаться #7

мухожук in Rust Async

(да, конечно же не 0, пофиксил)

источник

14:56пожаловаться #8

andor0 in Rust Async

или std::sync::mpsc::sync_channel(1)

источник

14:58пожаловаться #9

2018 August 05

мухожук in Rust Async

Смотрите, нубский вопрос

есть система из двух потоков, один listener, другой worker. Listener получает сообщение и отправляет его воркеру. Как переделать это на футуры?

Насколько я понял, по канонам токио нужно сделать тот же listener, но который на каждый входящий запрос будет спаунить таску

источник

20:51пожаловаться #10

мухожук in Rust Async

(Или же возможно стоит сразу переходить на акторы? всё равно пайплайн вида process -> send -> process -> send response)

источник

20:52пожаловаться #11

Nikita Vilunov in Rust Async

стримы?

источник

20:52пожаловаться #12

Berkus Decker in Rust Async

ну это стрим или канал