многопоточность — гонка данных C ++ shared_ptr и threadsanitazer

Это паста от ThreadSanitazer (Clang), которая сообщает данные гонки
http://pastebin.com/93Gw7uPi

Погуглив, кажется, это проблема с threadsanitazer (например, http://gcc.gnu.org/bugzilla/show_bug.cgi?id=57507)

Допустим, это выглядит так (написано от руки только для этого, поэтому это не рабочий код):

class myclass : : public std::enable_shared_from_this<myclass>
{
public:  // example!
myclass(boost::asio::io_service &io, int id);
~myclass() { /*im called on destruction properly*/ }
void start_and_do_async();
void stop();

int ID;
boost::asio::udp::socket usocket_;
... endpoint_;
... &io_;
}

typedef std::shared_ptr<myclass> myclass_ptr;
std::unordered_map<int, myclass_ptr> mymap;

myclass::myclass(boost::asio::io_service io, int id) : io_(io)
{
ID = id;
}

void myclass::start_and_do_async()
{
// do work here

//passing (by value) shared_ptr from this down in lambda prolongs this instance life
auto self(shared_from_this());
usocket_.async_receive_from(boost::asio::buffer(...),endpoint,
[this,self](const boost::system::error_code &ec, std::size_t bytes_transferred)
{
start_and_do_async();
}
}

void myclass::stop()
{
// ...some work and cleanups
usocket_.close();
}

в основном потоке создается новый поток (на самом деле это другой класс), который запускается для новых обработчиков io_service

new boost::thread([&]()
{
boost::asio::io_service::work work(thread_service);
thread_service.run();
});

и из основного элемента потока периодически добавляется или удаляется

void add_elem(int id)
{
auto my = std::make_shared<my>(thread_service, id);
my->start();
mymap[id] = my;
}

void del_elem(int id)
{
auto my = mymaps.at(id);
mymap.erase(id); //erase first shared_ptr instace from map

// run this in the same thread as start_and_do_async is running so no data race can happen (io_service is thread safe in this case)
thread_service.post[my]()
{
my.stop(); //this will finally destroy myclass and free memory when shared_ptr is out of scope
});
}

Таким образом, в этом случае, судя по документам (где говорится, что отдельный shared_ptr (boost или std) разрешает чтение / запись из нескольких потоков), может ли происходить гонка данных?

Правильно ли этот код создает два разных instaced shared_ptr для одного указателя?

В shared_ptr.h я вижу атомарные операции, поэтому мне просто нужно подтверждение того, что это проблема с обработчиком потока, сообщающим о ложных срабатываниях.

В моих тестах это работает правильно, без утечки памяти (экземпляры shared_ptr удаляются должным образом и вызывается деструктор), segfaults или чего-либо еще (10 часов вставки / удаления элементов — 100 в секунду или 1 в секунду)

0

Решение

Предполагая, что shared_ptr документация по безопасности потока соответствует его реализации, затем отчет о гонке данных на shared_ptr ложно-положительный. Потоки работают на разных экземплярах shared_ptr что доля собственности на тот же экземпляр. Следовательно, нет одновременного доступа к тому же shared_ptr пример.

С учетом сказанного я хочу подчеркнуть, что в этом примере безопасность потоков myclass::usocket_ зависит только от одного потока, обрабатывающего io_serviceэффективно выполняется в неявном нитка. Если несколько потоков обслуживают io_serviceто явное strand может быть использован для обеспечения безопасности потока. Для получения более подробной информации о некоторых тонкостях безопасности потоков с Boost.Asio и strandsрассмотреть вопрос о прочтении этот ответ.

1

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]