制作安全的读取器/写入器向量

Make a safe Reader/Writer vector

本文关键字：向量 读取 安全      更新时间：2023-10-16

受此代码的启发，我正在尝试实现一个可以安全地由线程并发调用push_back()的读取器/编写器vector。

一旦这个类就位，我就可以通过调用std::swap()来创建方法erase()，这将交换目标项和最后一个项，然后擦除集合中的最后一项。这样，我假设性能应该是公平的，因为在集合中间删除项目不会调用移动集合中目标项目后面的所有项目。

不幸的是，以下代码：

#include <vector>
#include <boost/thread/shared_mutex.hpp> //shared_mutex
#include <memory> //shared_ptr
#include <utility> //swap()
template <class T>
class readers_writer_vector
{
std::shared_ptr<boost::shared_mutex> pm;
std::vector<T> data;
public:
readers_writer_vector() :
pm(new std::shared_ptr<boost::shared_mutex>){}
void push_back(const T& item){
boost::unique_lock<boost::shared_mutex> lock(*pm); //wrong design
data.push_back(item);
}
};
int main()
{
readers_writer_vector<int> db;
db.push_back(1);
return 0;
}

产生以下编译错误：

/usr/include/c++/4.9/bits/shared_ptr_base.h:871:39: error: cannot convert ‘std::shared_ptr<boost::shared_mutex>*’ to ‘boost::shared_mutex*’ in initialization
: _M_ptr(__p), _M_refcount(__p)
// g++ -std=c++11 -Iboost -lboost t.cpp

我该如何解决？请！

编辑：

实施任务比我想象的要复杂得多。没过多久，我就遇到了@Danh警告过的问题。现在我收到这些错误：

t.cpp:28:8: note: ‘i::i(const i&)’ is implicitly deleted because the default definition would be ill-formed:
struct i {
^
t.cpp:28:8: error: use of deleted function      ‘readers_writer_vector<T>::readers_writer_vector(const readers_writer_vector<T>&) [with T = z]’
t.cpp:13:2: note: declared here 
readers_writer_vector(readers_writer_vector const&) = delete;

使用此版本：

template <class T>
class readers_writer_vector
{
booster::shared_mutex m;
std::vector<T> data;
public:
readers_writer_vector() = default;
readers_writer_vector(readers_writer_vector const&) = delete;
void push_back(const T& item){
booster::unique_lock<booster::shared_mutex> lock(m);
data.push_back(item);
}
typename std::vector<T>::reference back(){
return data.back();
}
};
struct z {
int zipcode;
std::string address;
};
struct i {
int id;
readers_writer_vector<z> zipcodes;
};
int main()
{
readers_writer_vector<i> db;
db.push_back(i());
auto &ii=db.back();
ii.id=1;
ii.zipcodes.push_back(z());
auto &zz=ii.zipcodes.back();
zz.zipcode=11;
zz.address="aa";
return 0;
}

除了修复现有错误之外，我还必须实现迭代器，以使readers_writer_vector类有用。

我正在考虑我是否应该继续...

因为pmstd::shared_ptr<boost::shared_mutex>不是std::shared_ptr<boost::shared_mutex>*。您可以使用它：

readers_writer_vector() :
pm(std::make_shared<boost::shared_mutex>()){}

无论如何，为什么需要指针/智能指针？这更适合：

template <class T>
class readers_writer_vector
{
boost::shared_mutex pm;
std::vector<T> data;
public:
void push_back(const T& item){
boost::unique_lock<boost::shared_mutex> lock(pm);
data.push_back(item);
}
};

你用错误的类型初始化pm;你实际上有

std::shared_ptr<> pm = new std::shared_ptr<>;

不能将共享指针从指针分配到共享指针。

将初始化器替换为

pm(new boost::shared_mutex)

或者直接使互斥锁成为成员，而不是使用共享指针。

相关文章：