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

С++ для начинающих

Войти
Регистрация
Восстановить пароль
 
Каян
2 / 2 / 0
Регистрация: 05.12.2011
Сообщений: 7
#1

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

05.12.2011, 22:08. Просмотров 651. Ответов 0
Метки нет (Все метки)

Решаю проблему по организации обработки очереди сообщений с 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 все работает прекрасно.
Вопрос - в чем проблема?
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
05.12.2011, 22:08     Конкурентная lock-free очередь
Посмотрите здесь:

lock-free vector - C++
Собственно вопрос, есть ли реализации lock free вектора?

Lock() and unlock() - C++
#include&lt;iostream&gt; #include&lt;thread&gt; #include&lt;mutex&gt; using namespace std; class arrayModifier { public: void invers(int...

Зачем fwrite вызывает lock? - C++
size_t __cdecl fwrite ( const void *buffer, size_t size, size_t count, FILE *stream ) {...

Программное управление NumLock \ CapsLock \ Sroll Lock - C++
Проблема следующая - есть устройство которое эмитируется под клавиатуру и управляется оно с помощью сигналов о включении светодиодов ...

Когда нужно лочить ( делать lock() ) сразу нескольких мьютексов - C++
Здравствуйте товарищи девелоперы! Прошу прощения за банальный в своем роде вопрос, однако когда мне может понадобиться сделать lock() на...

free - C++
Выделил память под массив(строку), размером 5 элементов. char *str; str = (char*)calloc(5,sizeof(char)); if (str == NULL) { ...

C-Free Standart - C++
Для формулы: Y=1.7*x+7.8*sin(2.1*x)+3.4*(х-1)-7.2 , A=-3,B=3,H=0.1. Составить программу построения таблицы значений функции при изменении...

free и метки - C++
Здравствуйте, господа. Никак не могу найти ответы на след. вопросы: 1). Для того, чтобы освободить выделенную ранее память,...

Компилятор C-Free - C++
Начинаю изучать язык программирования C++. Какой вы можете дать отзыв о вышеупомянутом компиляторе? Стоит ли его использовать? Если нет, то...

ошибка с free - C++
#define _CRTDBG_MAP_ALLOC #include &lt;stdlib.h&gt; #include &lt;crtdbg.h&gt; #include &lt;iostream&gt; #include &lt;conio.h&gt; #include &lt;math.h&gt; ...

calloc, free. - C++
как правильно выделить память для двумерного массива а, при m=5,n=10 используя функцию calloc. и как правильно ее освободить при помощи...

с free в delete - C++
Как эту функцию можно переписать с помощью delete? void A(int **p,int r){ int **pr; for(pr = p; pr &lt; pr + r; tr++) ...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru