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

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

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

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

05.12.2011, 22:08. Просмотров 600. Ответов 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 очередь
Посмотрите здесь:

free и метки C++
calloc, free. C++
ошибка с free C++
с free в delete C++
C++ Компилятор C-Free
C++ C-Free Standart
C++ lock-free vector
C++ free
Когда нужно лочить ( делать lock() ) сразу нескольких мьютексов C++
Lock() and unlock() C++
C++ Зачем fwrite вызывает lock?
C++ Программное управление NumLock \ CapsLock \ Sroll Lock

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

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

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