Телеграмм чат группы rust_offtopic страница 21952

Но я оставил кусок своей старой имплементации на случай, если всё-таки эликсир окажется слишком сложным

22:08пожаловаться #1

С

У меня фундаментально три джобы:
1. Веб-сервер слушает запросы и ставит таски в очередь второй джобе
2. Вторая джоба выполняет некоторый долгий процесс и докладывается о результатах третьей джобе
3. Третья джоба пингует меня в телеграм, на емейл, куда угодно

Я вижу actix-web, 2 канала и 2 футуры, без всяких актиксов и бойлерплейтов

22:08пожаловаться #2

EG

Сергей

Я вижу actix-web, 2 канала и 2 футуры, без всяких актиксов и бойлерплейтов

Угу
Что произойдёт, если одна из футур залипнет?

22:09пожаловаться #3

EG

Правильно, канал с бэкпрешшуром забьётся с другой стороны и всё нахуй сдохнет

22:09пожаловаться #4

С

Правильно, канал с бэкпрешшуром забьётся с другой стороны и всё нахуй сдохнет

Здесь ты в любом языке решаешь, терять или не терять данные. Если решаешь терять, возьми теряющий канал на рингбуфере

22:10пожаловаться #5

EG

Не говоря уж о том, что просто прокинуть этот канал внутрь актикс-веба — это создавать тип, причём Send + Sync, оборачивать его в web::Data, совать в апп и вытаскивать с другой стороны. Это и есть бойлерпллейт

22:10пожаловаться #6

EG

Сергей

Здесь ты в любом языке решаешь, терять или не терять данные. Если решаешь терять, возьми теряющий канал на рингбуфере

Кроме того языка, который сможет запустить ещё один процесс за меня

22:11пожаловаться #7

С

Кроме того языка, который сможет запустить ещё один процесс за меня

процесс это что в твоих терминах?

22:11пожаловаться #8

EG

Процесс — это таск

22:11пожаловаться #9

EG

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

22:11пожаловаться #10

С

Кто тебе мешает спавнить одну и ту же футуру в расте?

22:12пожаловаться #11

EG

А, да, как только у тебя в расте есть футуры — у тебя есть двухцветные функции и сплит экосистемы. Ты больше не можешь делать tracing::span!(), например, тебе нужно изощряться с .instrument()
Чтобы запустить что-то тяжёлое и не убить токио, нужно делать web::block. Причём спаун из токио работать не будет, разные рантаймы.

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

С

Не говоря уж о том, что просто прокинуть этот канал внутрь актикс-веба — это создавать тип, причём Send + Sync, оборачивать его в web::Data, совать в апп и вытаскивать с другой стороны. Это и есть бойлерпллейт

А в замыкание точно нельзя пихнуть?

22:13пожаловаться #13

EG

Сергей

А в замыкание точно нельзя пихнуть?

Тебе нужно Sender получить из хендлера. Единственный разумный способ это сделать — это пихать его в web::Data

22:13пожаловаться #14

EG

Одноцветная асинхронность это вообще невероятный плюс

22:13пожаловаться #15

EG

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

22:15пожаловаться #16

s

suhr in rust_offtopic

https://www.hillelwayne.com/post/tla-golang/

Да, а потом дедлоки дебажишь неделями

Hillel Wayne

Finding Goroutine Bugs with TLA+ • Hillel Wayne

My job these days is teaching TLA+ and formal methods: specifying designs to find bugs in them. But just knowing the syntax isn’t enough to write specs, and it helps to have examples to draw from. I recently read Chris Siebenmann’s Even in Go, concurrency is still not easy and thought it would make a good case study for writing a spec. In it, he gives an example of Go code which deadlocks:

22:15пожаловаться #17

С

человек бойлерплейт не хочет писать, а ыт предлагаешь весь его код написать два раза )

22:16пожаловаться #18

s

suhr in rust_offtopic

Модель это не весь код.

22:17пожаловаться #19

С

А, да, как только у тебя в расте есть футуры — у тебя есть двухцветные функции и сплит экосистемы. Ты больше не можешь делать tracing::span!(), например, тебе нужно изощряться с .instrument()
Чтобы запустить что-то тяжёлое и не убить токио, нужно делать web::block. Причём спаун из токио работать не будет, разные рантаймы.

Зачем ты хочешь делать web::block? Читай синхронно из ресивера в отдельном синк треде и делай там таск. Или spawn_blocking, который сделает тебе тоже самое.