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

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

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

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

05.12.2011, 22:08. Просмотров 673. Ответов 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 очередь (C++):

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

Очередь (сделать очередь, чтобы добавляло, удаляло, читало. Не STL.) - C++
Помогите пожалуйста написать очередь. Есть Температура double и ее тип int ну и нужно сделать очередь, чтобы добавляло, удаляло, читало....

Сформировать очередь по файлу целых чисел. Промоделировать очередь в супермаркете - C++
Сформировать очередь по файлу целых чисел. Промоделировать очередь в супермаркете. В каждый момент времени происходит одно из событий:...

Задача на очередь (вывод сообщения, что очередь пуста) - C++
Доброго дня! Есть задачка на очередь, которая работает нормально, только надо добавить код, чтобы выводил сообщение, что очередь пуста.....

Очередь, теория. Очередь на шести стеках - C++
Здравствуйте, пытаюсь побольше найти информации про очереди и их применение в программировании. Из того что я нашел, все описывается лишь...

Создать очередь. Добавить элемент в очередь. Удалить элемент из очереди - C++
Нужно создать очередь. Добавить элемент в очередь. Удалить элемент из очереди. Вот моё &quot;творение&quot;. int main() { int...

Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
05.12.2011, 22:08
Привет! Вот еще темы с ответами:

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() на...


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

Или воспользуйтесь поиском по форуму:
Ответ Создать тему
Опции темы

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