хочу добавить переменную, ктороая подобна существующей

но с другими свойствами

а здесь у читателей random access по сути

Почему рандом? Они не первую живую запись читают?

нет

timer = pygame.time.Clock() x=y=0 # координаты for row in level: # вся строка for col in row: # каждый символ if col == "-": pf = Platform(x,y) entities.add(pf) platforms.append(pf) x += PLATFORM_WIDTH #блоки платформы ставятся на ширине блоков y += PLATFORM_HEIGHT #то же самое и с высотой x = 0 #на каждой новой строчке начинаем с нуля total_level_width = len(level[0])*PLATFORM_WIDTH # Высчитываем фактическую ширину уровня total_level_height = len(level)*PLATFORM_HEIGHT # высоту camera = Camera(camera_configure, total_level_width, total_level_height)

они могут зареквестить любую запись и получить ее, если она все еще есть в буфере

А как реквестить? По номеру, по хэшу?

по таймстемпу

=, >=?

интервал

Деревом поиска можно

2.7

ну условно "а дайте мне запись из интервала от 15 до 17 секунд назад"

Все операции за логарифм

не, как искать понятно

да и даже последовательно не так страшно

меня в принципе напрягает такая идея, что "не чувак, ты захотел слишком старое, мы это уже выкинули"

Если напрягает, не выкидывай

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

и вовремя

Вовремя подразумевает wait-free или необязательно?

да

Тогда сложно

особенно беда с потенциальными гонками при обращении читателя к чему-то древнему

он может получить или "нету уже, удалили", или же успеет ухватить, а тогда писателю писать некуда

Ну лок фри делается на кольцевом буфере вроде, а вейт фри не знаю

он может получить или "нету уже, удалили", или же успеет ухватить, а тогда писателю писать некуда

Так сначала берем номер, потом обращаемся

кто юзал openpyxl для excel таблиц в питоне? как сделать ширину колонок под содержимое? (autofit) в доках и кастомные методы не работают

И hazard pointer для защиты от удаления

ну так вот защита от удаления и означает "некуда писать"

это эмбеддед, к тому же без динамического выделения памяти

А объект помещается в машинное слово?

нет

размер объекта порядка килобайта

Если в очереди помещается не меньше объектов, чем всего ридеров, hazard pointer справится

ну это как раз и есть "я захватил, модифицировать нельзя". И да, удаление должно быть все-таки по возрасту

то есть нельзя удалить более молодую запись, если более древнюю держит какой-то ридер

хотя я подумаю над этим

ну это как раз и есть "я захватил, модифицировать нельзя". И да, удаление должно быть все-таки по возрасту

Если уже захвачено, удалять не надо при любом возрасте

Потому что он ее сейчас обрабатывает

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

В смысле? Он же не моментально отрабатывает

Он захватил и заснул, в это время новое добавилось

в смысле "у нас в буфере есть место под 100 записей. Если нашелся ридер, которому почему-то нужна аж 100-я, то это явно какой-то косяк в алгоритме"

и если не косяк, то надо увеличивать буфер

То есть ридер обязан отработать мгновенно?

100 записей приходят не сразу, а в определенном предсказуемом темпе

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

то есть нагрузка должна быть ровной и равномерной (эмбеддед же), без пиков

Тогда это совсем другая задача

Я думал, что лок фри надо

ок. Попробую переформулировать. Есть один или несколько райтеров, каждый из которых со стабильным темпом кладет записи в буфер. Соответственно можно сразу сказать, какое время записи в буфере живут - размер буфера делим на скорость появления новых записей.

Тогда просто выбираем первую подходящую запись и читаем ее

каждый ридер независимо от других обращается к разным записям, как правило относительно текущего таймстемпа, но не всегда им нужна самая последняя запись - некоторым (алгоритм такой) нужны в том числе и более старые

Он может несколько посмотреть?

то есть "дайте мне запись свежее таймстемпа 100500" и "дайте мне запись из интервала 100400-100450"

может

Ну вот, пусть начнет с самой ранней и идет вперед

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

то есть он инплейс смотрит запись, что-то у себя считает и так далее

ERROR: S client not available

как именно он это делает - вопрос ридера, ридеры могут быть разными, но каждый должен (ожидается) успевать на текущем буфере отрабатывать с учетом нагрузки системы

соответственно ситуация, когда оказывается, что запись, которую райтер должен быть переиспользовать, а она прям щас захвачена каким-то ридером, я воспринимаю как "ну блин, не успели"

нагрузка оказалась выше расчетной, ридер не успел отработать, что-то еще.

фишка с тем, что ридер может прийти с запросом "хочу запись от таймстемпа 123456", а система видит, что такой записи _еще_ нет, поэтому ридер блочится -- это так, бонус.

Ну пусть в спинвейте крутится

кондвар можно, не проблема

Есть такая фича в питоне чтобы последнее выражение в методе было возвращаемым значением?

Нет

Есть такая фича в питоне чтобы последнее выражение в методе было возвращаемым значением?

не, все через return

Привет, а никто не знает "hacky" способ чтобы сделать сделать асинхронные функции (сопрограммы) само-awaitable ? (т.е. чтобы не нужно было каждый раз дописывать слово await) (с этим постоянно проблемы)

Есть такая фича в питоне чтобы последнее выражение в методе было возвращаемым значением?

Ну разве что лямбда может подойти.

Привет, а никто не знает "hacky" способ чтобы сделать сделать асинхронные функции (сопрограммы) само-awaitable ? (т.е. чтобы не нужно было каждый раз дописывать слово await) (с этим постоянно проблемы)

А зачем тогда вообще асинк?

Ну разве что лямбда может подойти.

жяль

А зачем тогда вообще асинк?

чтобы не ждать ответа от сервера - быстрее

эх, если бы придумали асинхронный по дефолту язык..

эрланг?

чтобы не ждать ответа от сервера - быстрее

Ты ж его синхронно хочешь запустить

(хочу именно в проект на aiohttp впихнуть) (знаю что есть greenlet, но уже есть готовый код)

эрланг - модель акторов, она ассинхронна по дефолту

да, но сделать сущность, которая без await бы возвращала данные из сопрограммы

что-то по типу asyncio.run, только для каждой корутины

Привет, а никто не знает "hacky" способ чтобы сделать сделать асинхронные функции (сопрограммы) само-awaitable ? (т.е. чтобы не нужно было каждый раз дописывать слово await) (с этим постоянно проблемы)

http://zderadicka.eu/functional-fun-with-asyncio-and-monads/

http://zderadicka.eu/functional-fun-with-asyncio-and-monads/

спасибо большое, сейчас посмотрю

монадическая семантика с мапом и флатмапом скорее всего что ты хочешь

http://zderadicka.eu/functional-fun-with-asyncio-and-monads/

?

тебе await нужно будет только в самом конце, няп что там написано

понял, спасибо. Какой-никакой - выход, но еще не уверен что это подойдет

может ли кто нибудь объяснить новичку - что есть что на конкретном примере

может ли кто нибудь объяснить новичку - что есть что на конкретном примере

@ru_python_beginners