У меня возникла проблема с созданием кольцевого буфера фиксированного размера без блокировки.
У нас есть 2 обновления во время вставки или отправки.
Первое обновление — это обновление хвостового указателя.
Второе обновление — это обновление фактического местоположения данных.
Даже если мы получим правильное первое обновление, прежде чем мы выполним второе обновление, другой поток потенциально может обернуться и перезаписать местоположение.
Как я могу сделать и то, и другое без блокировки?
Подход с тегами позволяет избежать проблемы ABA, но позволяет решить проблему двух обновлений.
bool push(const T& item) {
TaggedHandle tail, next;
do {
tail = tail_.load();
next = tail.next();
if (next.index == head_.load().index) {
return false; // Buffer is full
}
} while (!tail_.compare_exchange_strong(tail, next));
buffer_[tail.index] = item; // This update can be corrupted if other threads wraps arounds and updates??
return true;
}
Подробнее здесь: https://stackoverflow.com/questions/790 ... fixed-size
Существует ли реальная реализация кольцевого буфера без блокировки фиксированного размера? ⇐ C++
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Как я могу управлять общей памятью в пользовательском типе данных кольцевого буфера?
Anonymous » » в форуме Python - 0 Ответы
- 13 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Как я могу управлять общей памятью в пользовательском типе данных кольцевого буфера?
Anonymous » » в форуме Python - 0 Ответы
- 9 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Как я могу управлять общей памятью в пользовательском типе данных кольцевого буфера?
Anonymous » » в форуме Python - 0 Ответы
- 9 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Как я могу управлять общей памятью в пользовательском типе данных кольцевого буфера?
Anonymous » » в форуме Python - 0 Ответы
- 7 Просмотры
-
Последнее сообщение Anonymous
-