Форум программистов, компьютерный форум CyberForum.ru

Конкурентная lock-free очередь - C++

Восстановить пароль Регистрация
Другие темы раздела
C++ Реализовать класс Money используя класс Fraction http://www.cyberforum.ru/cpp-beginners/thread399754.html
1)Создать класс Money для работы с денежными суммами.Число должно быть представлено двумя полями: типом long для рублей и типом unsigned char - для копеек. дробная часть(копейки) при выводе на экран должна быть отделена от целой части запятойю реализовать сложение,вычитание, деление сумм, деление суммы на дробное число, умножение на дробное число и операцию сравнения. 2) создать класс Fraction...
C++ Как лучше учить С++ Уважаемые форумчане. Поделитесь пожалуйста опытом (кто каким может). Как лучше и быстрее изучить Си, с помощью каких программ, иль литературу какую почитать, книги умные? Может к репетиторам податься? Есть ли вообще репетиторы которые преподают С++, если есть то как с ними связаться? Большое спасибо за помощь и понимание. http://www.cyberforum.ru/cpp-beginners/thread399738.html
C++ Переменную типа string вывести в printf?
как в переменную типа string вывести в printf? #include <stdio.h> // для принтф #include <stdlib.h> #include <string> using namespace std; int main() {
Вычисление функции с заданной точностью с использованием разложения в ряд C++
Цель работы: освоение средств языка C++ для описания итерационных циклов и закрепление навыков использования их при программировании. Пример Задание. Составить схему программы и программу на языке C++ с использованием оператора цикла с предусловием и оператора цикла с постусловием для вычисления функции с заданной точностью с использованием разложения в ряд 2 программы: Программа с...
C++ Функции <string.h> http://www.cyberforum.ru/cpp-beginners/thread399724.html
Привет! Хочу сделать такую штуку: есть строка. Надо найти в ней все знаки ". ! ?" и букву, идущую после любого из этих знаков, сделать прописной. Надо сделать с использованием функций из библиотеки <string.h>. Заготовка: #include <stdio.h> #include <ctype.h> #include <string.h>
C++ робота с лентами Составить блок-схемы алгоритмов и программу на языке С для обработки текстового файла с использованием разработанных функций для работы с лентами. Оформить выполнения одного из заданий в виде подпрограммы. задание Сформировать и вывести на экран текстовый файл, в котором пробелы заменяются символом подчеркивания. Подсчитать количество арифметических операций (+,-,*,/) в файле. подробнее

Показать сообщение отдельно
Каян
2 / 2 / 0
Регистрация: 05.12.2011
Сообщений: 7
05.12.2011, 22:08     Конкурентная lock-free очередь
Решаю проблему по организации обработки очереди сообщений с lock_free подходом.
В односвязную очередь пишет одновременно неограниченное кол-во писателей и принимает сообщения только один читатель, который периодический берет в себе всю текущую очередь целиком и обрабатывает ее.

Организовал я это так:
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
/*элемент очереди со значением record и указателем на следующее звено next*/
struct STAT_CHAIN{
     STAT_RECORD *record;
    volatile STAT_CHAIN *next;
    STAT_CHAIN(STAT_RECORD *_record) : record(_record)
    {
        next = NULL;
    }
 
    ~ STAT_CHAIN()
    {
        delete record;
    }
};
/*указатель на первый элемент очереди*/
volatile STAT_CHAIN *_statistics;
 
/*реализация атомарного Exchange, обменивающего две ссылки*/
unsigned int InterlockPointerSwap(volatile void *pp,void *pNew){        
    return InterlockedExchange((unsigned int*)pp,*(unsigned int*)pNew);
}
/*реализация атомарного CompareExchange со ссылками*/
unsigned int InterlockPointerCompareSwap(volatile void *pp,void *pNew,void *comper){        
    return InterlockedCompareExchange((unsigned int*)(pp),*(unsigned int*)pNew,*(unsigned int*)comper);
}
/*запись в очередь. По задумке создаем звено и пытаемся его поместить в качестве начального, в качестве продолжения указав ему текущее начальное (т.е. вставляем в начало новый элемент) */
void __fastcall push(STAT_RECORD *record)
{
    STAT_CHAIN *chain = new STAT_CHAIN(record);     
    do{   
        chain->next = _statistics;     
    }while((unsigned int)chain->next != InterlockPointerCompareSwap(&_statistics,&chain,&chain->next));
}
 
/*это вызывающийся регулярно метод-чтец обработки имеющейся на момент обработки очереди. Должен брать начальное звено (и все, что из него растет) и в качестве начального помещать NULL*/
void process_queue(){           
    volatile STAT_CHAIN *stack = NULL;
    stack = (STAT_CHAIN*)InterlockPointerSwap(&_statistics,&stack);
    while (NULL != stack){          
        STAT_RECORD *record = stack->record;    
//   ...
//обработка записи
//  ...
        volatile STAT_CHAIN* nstack = stack->next;      
        delete stack;       /*<---ЗДЕСЬ ПРОБЛЕМА*/
        stack = nstack;
    }   
}
Проблема в следующем: при осуществляющемся освобождении памяти звена происходит ошибка обращения к памяти в некоторый последующий момент (как будто я удаляю еще необработанное звено). Проверка флажком (вместо удаления поднимал искусственный флажок isDeleted у звена) не показала никаких симптомов дублирования звеньев (т.е. попытки обращения к явно удаленному звену не было). Соответственно, с закомментированным delete все работает прекрасно.
Вопрос - в чем проблема?
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
 
Текущее время: 07:36. Часовой пояс GMT +3.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2016, vBulletin Solutions, Inc.
Рейтинг@Mail.ru