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

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

Восстановить пароль Регистрация
 
Каян
2 / 2 / 0
Регистрация: 05.12.2011
Сообщений: 7
05.12.2011, 22:08     Конкурентная lock-free очередь #1
Решаю проблему по организации обработки очереди сообщений с 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 очередь
Посмотрите здесь:

Задача на очередь (вывод сообщения, что очередь пуста) C++
C++ lock-free vector
C++ free
Создать очередь. Добавить элемент в очередь. Удалить элемент из очереди C++
Когда нужно лочить ( делать lock() ) сразу нескольких мьютексов C++
Lock() and unlock() C++
C++ Зачем fwrite вызывает lock?
Очередь, теория. Очередь на шести стеках C++

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

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

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