Я пытаюсь использовать tbb :: concurrent_hash_map в запущенной задаче, но я сталкиваюсь с проблемой, которая вызывает erase () карты, вызывает бесконечную блокировку задачи. Есть идеи, что может быть не так с фрагментом ниже?
#include <iostream>
#include <boost/date_time.hpp>
#include <tbb/concurrent_hash_map.h>
#include <tbb/task_group.h>
#include <tbb/task_scheduler_init.h>
class BusyTask
{
public:
void operator()() {
typedef tbb::concurrent_hash_map<unsigned int, int> MyMap;
MyMap m;
MyMap::accessor a;
m.insert(a, 1);
m.erase(1); // The task will lock up at this point
}
};
int main(int argc, char* argv[])
{
std::cout << "Started" << std::endl;
BusyTask busyTask1;
tbb::task_group taskGroup;
taskGroup.run(busyTask1);
taskGroup.wait();
std::cout << "Finished" << std::endl;
return 0;
}
Я тестирую с TBB v4.0.5 и GCC 4.7
Как правильно отмечено в комментарии, это проблема блокировки области. erase(1)
необходимо получить такую же блокировку, которая уже получена операцией insert () (и блокировки не являются рекурсивными).
Обратите также внимание на метод стирания (by_accessor) хэш-карты, который гарантирует, что будет удален именно элемент, защищенный средством доступа, а не другой элемент с тем же ключом. Последнее может произойти, если параллельные потоки стерли его (предоставив один и тот же ключ) и добавили новый элемент с тем же ключом.
Других решений пока нет …