АВ
Size: a a a
2020 March 05
АВ
Пусть так и будет
DF
Ну мысль правильная
DF
Либо свой актор с мейлбоксом на 1 реквест,либо каналы
p
Канал, который принимает таску и ваншот ванал, по которому отправляется результат выполнения таски?
тип при инициализации обменятся двумя каналами, один для request, другой для answer?
IA
мне нужно общаться между потоками между двумя объектами
процесс общения:
как это реализовать можно? суть в том, что пока справа идет обработка, слева поток должен быть не заблокирован, и отвечать на взаимодействие юзера
процесс общения:
| wait |
| ... |
| ... |
|request->|
| |
|handle |
|request |
| |
|<- anwer |
| wait |как это реализовать можно? суть в том, что пока справа идет обработка, слева поток должен быть не заблокирован, и отвечать на взаимодействие юзера
Серьезно, в расте есть аналог boost_spsc, называется channel
АВ
тип при инициализации обменятся двумя каналами, один для request, другой для answer?
Ща набросаю
АВ
Серьезно, в расте есть аналог boost_spsc, называется channel
Да мы знаем, это же прямо в растбуке написано
DF
Единственный момент есть ли в расте что то типа селекта
p
к слову связь создается при создании приложения, и разрушается только при окончании, если это важно
DF
Штоб можно было и событиЯ юзера и респонс ждать
IA
Я просто плюсовик, только начинаю въезжать. Смотрю аналогичные штуки на расте
MV
тип при инициализации обменятся двумя каналами, один для request, другой для answer?
https://t.me/rust_async
можно вот тут поспрашивать ещё, а вообще это распространённый паттерн:
https://rust-lang.github.io/async-book/06_multiple_futures/03_select.html
можно вот тут поспрашивать ещё, а вообще это распространённый паттерн:
https://rust-lang.github.io/async-book/06_multiple_futures/03_select.html
DS
Как шарить очереди между потоками в crossbeam_queue?
DS
Они у них Sync, но не Clone и Copy
MV
Как шарить очереди между потоками в crossbeam_queue?
arc?
DS
Спасибо, что-то забыл. А он же с блокировкой?
MV
с атомиком, да
АВ
Ваншот каналов нет в стд, как я понимаю, так что там обычный