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

О кидай

16:36пожаловаться #1

Alex Bubnov in pro.elixir

"и, кажется, небезынтересное видео, которое я пока не посмотрел - https://www.youtube.com/watch?v=pq-Pa2Fj4nE россберг про всякое, в том числе про эффекты, через которые предположительно будут continuations
и слайды чисто про continuations, там всё довольно понятно https://github.com/WebAssembly/meetings/blob/master/main/2020/presentations/2020-02-rossberg-continuations.pdf"
https://t.me/proelixir/168863

16:37пожаловаться #2

Я посмотрел по диагонале, понял чуть больше чем нихуя, но чисто тик не нашел.

А если делать вызов функции на двух процессах?
1 - непосредственно нифка
2 - обработчик с колбеками.

Говорим 2 дернуть нифку на 1. 1 посылает сообщение 2 “ща дерну”, дергает, послыает 2 “дернул, получилось что-то там”

19:53пожаловаться #3

ŹR

Ну там плюс минус так и работает. Поэтому и утекает

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

2021 June 09

Видимо я тупой. Не понимаю почему оно должно утекать

16:05пожаловаться #5

ŹR

Нельзя выйти из нифки посередине. 1 заблочится навсегда

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

А там такая нифка что она не кончается никогда?

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

ŹR

Нифка блочится в момент колбэка. Допустим из нифку можно послать сообщение внутрь 2 «дёрни такой колбэк». Но как получить ответ?

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

Ааа понял, да

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

ŹR

Получить ответ можно, если первоначально запустить wasm в отдельном треде в нифке. Тогда можно будет из 2 вызвать другую функцию в нифке, которая сможет послать результат колбэка в этот тред.

Вот только если колбэк упадёт до вызова нифки - этот тред будет висеть до конца beam

16:19пожаловаться #10

ŹR

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

Но вот в этом месте я как раз и остановился

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

ŹR

А диспоузится он в момент GC. Например. Если умрет процесс 2, то тред тоже умрет

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

ŹR

Осталось только запилить

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

Ну круто👍

16:24пожаловаться #14

ŹR

Я в этот момент понял что надо чинить rustler и пошел коммитить туда

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

ŹR

А потом я просто забил и все

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

Bogdan in pro.elixir

last_ids
    |> Task.async_stream(fn last_id ->
      from(b in B,
        where: b.id > ^last_id,
        limit: 3_500,
        order_by: [:id]
      )
    end)

Помогите query оптимизировть, чтобы без Task.async_stream запускать.

last_id хранится в таблице A. хочу получить данные ввида через одну query.


[
%A{
b_list: [
%B{
…some_data
}
…
]}]

Собственно тоже самое что и сейчас но только без Task.async_stream 🙂

16:38пожаловаться #17

Anastasiya Dyachenko in pro.elixir

здесь в любом случае n+1 запрос, т.к. для каждой записи a нужно делать отдельный запрос

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

Anastasiya Dyachenko in pro.elixir

вижу только вариант выбирать все записи из B и далее в коде распределять по записям A

16:49пожаловаться #19

Anastasiya Dyachenko in pro.elixir

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