member x.Channel() =
let mailbox () =
let chan = Channel.CreateUnbounded<unit>()
let rec loop () =
async {
do! chan.Reader.ReadAsync().AsTask() |> Async.AwaitTask
return! loop ()
}
loop () |> Async.StartImmediate
chan
let processors = [| for _ in 0 .. 100_000 -> mailbox () |]
let messagesCount = 1_000_000
let random = Random(messagesCount)
for i in 0 .. messagesCount do
let t = random.Next(0, 100_000 - 1)
let mailbox = processors.[t]
mailbox.Writer.WriteAsync(()) |> ignore
Мне интересно
Vladislav
Vladislav
Но вообще
Vladislav
Похоже что у тебя асинк рекурсия насрала в память
Vagif
А что это вообще?
Vladislav
Запусти доттрейс или как его
Vagif
Читается нелегко.
Vladislav
Точнее кушающий меньше всего
Vagif
А, вижу выше, у Айрата.
Nikolay
Там Айрат кидал
Vagif
Вообще интересный тест.
Vagif
Но я сейчас траву сажаю, активно присоединиться не могу :-)
Vasily
Nikolay
Надо будет написать покрасивее и с ожиданием
Nikolay
Я тут тоже за компом набегами
Крылатый
Nikolay
Nikolay
public void ChannelCSharp()
{
Channel<Unit> GetMailbox()
{
var channel = Channel.CreateUnbounded<Unit>();
async ValueTask Loop()
{
var r = await channel.Reader.ReadAsync();
await Loop();
}
var _ = Loop();
return channel;
}
var processors = new Channel<Unit>[100_000];
for (var i = 0; i < processors.Length; i++)
{
processors[i] = GetMailbox();
}
var messagesCount = 1_000_000;
var random = new Random(messagesCount);
for (var i = 0; i < messagesCount; i++)
{
var t = random.Next(0, 100_000 - 1);
var mailbox = processors[t];
mailbox.Writer.WriteAsync(null);
}
}
Nikolay
На фшарпе почти гиг было
Nikolay
Видимо из-за асинков
Vladislav
Все так
Vladislav
Из-за CE
Nikolay
На 60 мб больше если ValueTask заменить на Task
Nikolay
Nikolay
Мде
Hog
о, а там есть ченить готовое для head tracker-а? а то я на основе freeTrack спаял схемку, но сам софт староват и весьма капризен
Там есть фейс детекшон. А трекать я ещё не пробовал.
Nikolay
Шо
Ayrat
Они нужны когда ты возвращаешь синхронно, без ожидания. А ты явно ожидаешь
Vladislav
Они нужны когда ты возвращаешь синхронно, без ожидания. А ты явно ожидаешь
Там канал на валуетасуах написан
Hog
Vladislav
Сам
Vladislav
Return await
Vladislav
Либо вообще без него
Vladislav
Await
Ayrat
Да, код не очень
Nikolay
Разница на вставку с гопаком 100 мс
Nikolay
Надо бы эвейт сделать
Ayrat
Гопак у меня в крови
Ayrat
Ты кот покажи
Nikolay
public void ChannelCSharp()
{
Channel<Unit> GetMailbox()
{
var channel = Channel.CreateUnbounded<Unit>();
async ValueTask Loop()
{
while (true)
{
var r = await channel.Reader.ReadAsync();
}
}
var _ = Loop();
return channel;
}
var processors = new Channel<Unit>[100_000];
for (var i = 0; i < processors.Length; i++)
{
processors[i] = GetMailbox();
}
var messagesCount = 1_000_000;
var random = new Random(messagesCount);
for (var i = 0; i < messagesCount; i++)
{
var t = random.Next(0, 100_000 - 1);
var mailbox = processors[t];
mailbox.Writer.WriteAsync(null);
}
}
Nikolay
member this.Hopac() =
let loop = Mailbox.take >> Job.foreverServer >> start
let processors = [| for _ in 0 .. 100_000 -> Mailbox() |]
Array.iter loop processors
let msgCount = 1_000_000
let random = Random msgCount
for i = 0 to msgCount do
let t = random.Next(0, 100_000 - 1)
let mb = processors.[t]
Mailbox.send mb ()
|> start
Ayrat
Все ещё не понимаю этих ваших рандомных мейлбоксов и измерения времени асинков без ожидания
Ayrat
Ты бы уже написал то, что измеряет ответ мейлбоксов
Nikolay
Да мне пока аллокации интересны
Nikolay
Попробую с эвейтом сделать
Vladislav
Код недосягаемый
Nikolay
Вай?
Vladislav
Ну мб
Nikolay
Вот без лупа и с лупом
Nikolay
Nikolay
Ayrat
Да это все равно дичь
Vladislav
Присамоньте Егора сюда
Nikolay
148 мб аллоцируют просто 100к ченелов
Nikolay
Дичь какая-то
Ayrat
Нихуя себе
Nikolay
126 мб
Nikolay
Вот щас верно посчитал
Ayrat
Ну по килобайту на объект.
Ayrat
Если чо, это 1000 байт
Ayrat
Ну почти)
Nikolay
Ну такое хз
Ayrat
Это дохуя
Nikolay
А щас попробую последний превью
Ayrat
Это прям жирный объект