Удалить последний элемент очереди

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

Используется такой способ для передачи указателей на данные в цикл. буфере. Пока последний элемент очереди другим потоком не прочитан, его можно обновить, чтобы передать больше данных.
Сейчас делаю очередь из 2 элементов. И при необходимости запоминаю значение первого, очищаю всю очередь, наполняю ее заново. Функции для сего безобразия не нашел. Это можно сделать, если залезть в сами исходники queue.c, но тогда теряется приватность.

Подскажите, может я что проглядел?

0

Зачем очищать? Просто дублируйте его куда-нибудь рядом. А с вычитывающей стороны поставьте проверку - если вычитывается _последний_ элемент, то брать его из "отдельной" ячейки. Не забудьте обеспечить атомарность записи в эту ячейку (исключить незащищенную побайтовую запись слова).

0

Сообщение от u37 Зачем очищать? Просто дублируйте его куда-нибудь рядом. А с вычитывающей стороны поставьте проверку - если вычитывается _последний_ элемент, то брать его из "отдельной" ячейки. Не забудьте обеспечить атомарность записи в эту ячейку (исключить незащищенную побайтовую запись слова).

не понял кого дублировать

Расскажу подробнее
-очередь пустая, размер 2 элемента
-поток tx смотрит, что очередь пустая, пишет туда указатель и размер появившихся данных.
-пришли еще данные, поток tx видит, что место в очереди еще есть, добавляет туда указатель и размер на новую часть данных
-снова пришли данные, поток rx так и не успел их прочитать, поэтому очередь заполнена. Поток tx должен обновить размер данных в последнем элементе, для этого запоминается первый элемент, вся очередь очищается, первый элемент возвращается на место а во второй записываются обновленные данные

Идея была в том, чтобы пока поток rx читает первый элемент очереди, актуализировать второй элемент. Таким образом всю работу насчет одновременного доступа к памяти берет на себя ОС за счет механизма очередей.

Можно вообще оставить в очереди один элемент. Но тогда я не знаю как разрешить ситуацию:
поток rx начал читать из очереди, а прерывание (оно же "поток" tx) получило данные и хочет добавить их в очередь. Ждать освобождения очереди, находясь в прерывании - не вариант

0

Чего только народ не придумает...
Сделайте либо больше очереди, либо возьмите проц помощнее. Остальное все извраты непонятно зачем.

0

Этот "изврат" придумывался чтобы не забивать очередь передачей однобайтовых кусков данных, а передавать обработчику актуальный размер по готовности. Размер данных и окончания заранее не известен.

0

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

0