（ab）使用shared_ptr作为参考计数器
|
最近我想到了一个狡猾的计划（tm：P））
我必须在程序中更新设置结构（每15秒说一次）。设置结构由多个功能使用，并且每个功能均由多个线程调用。
因此，我需要一个参考计数器来知道何时可以安全地释放旧设置结构。
那么这是正确的方法吗？
如果您没有仔细阅读代码，请不要回应它是可以的，当涉及到共享指针时，在进行此类滥用时很容易出错（请相信我）。
编辑：我忘了提到重要的部分。我认为该实现可防止ref计数器下降到0，因为我在updateSettings（）中对其进行了初始化，并且直到再次调用它时它才会下降（然后myFucntion使用内存中的2个设置中的另一个）。
#include<memory>
#include <cstdio>
#include <iostream>
#include <vector>
using namespace std;
struct STNGS
{
int i;
vector<double> v;
};
static int CUR_STNG=0;
shared_ptr<STNGS> stngsArray[2];
int myFunction() //called by multiple threads
{
shared_ptr<STNGS> pStngs=stngsArray[CUR_STNG];
STNGS& stngs=*pStngs;
//do some stuff using stngs
}
void updateSettings()
{
auto newIndex=(CUR_STNG+1)%2;
stngsArray[newIndex].reset(new STNGS);
CUR_STNG=newIndex;
}
void initialize()
{
auto newIndex=CUR_STNG;
stngsArray[newIndex].reset(new STNGS);
CUR_STNG=newIndex;
}
int main()
{
initialize();
//launch bunch of threads that are calling myFunction
while(true)
{
//call updateSettings every 15 seconds
}
}
#include<memory>
#include <cstdio>
#include <iostream>
#include <vector>
using namespace std;
static const int N_STNG_SP=4;
static int CUR_STNG=0;
struct STNGS
{
int i;
vector<double> v;
STNGS()
{
for (int i=0;i<10;++i)
v.push_back(42);
}
};
shared_ptr<STNGS> stngs[N_STNG_SP];
int myFunction() //called by multiple threads
{
shared_ptr<STNGS> pStngs=stngs[CUR_STNG];
STNGS& stngs=*pStngs;
//do some stuff using stngs
}
void updateSettings()
{
auto pStng=new STNGS;
//fill *pStng
int newVer=(CUR_STNG+1)%N_STNG_SP;
stngs[newVer].reset(pStng);
CUR_STNG=newVer;
}
void initialize()
{
auto pStng=new STNGS;
//fill *pStng
int newVer=(CUR_STNG+1)%N_STNG_SP;
stngs[newVer].reset(pStng);
CUR_STNG=newVer;
}
int main()
{
initialize();
//launch bunch of threads that are calling myFunction
while(true)
{
//call updateSettings every 15 seconds
updateSettings();
}
}
没有找到相关结果
已邀请:
1 个回复
凸晴
template<class T> bool atomic_is_lock_free(const shared_ptr<T>* p); template<class T> shared_ptr<T> atomic_load(const shared_ptr<T>* p); template<class T> shared_ptr<T> atomic_load_explicit(const shared_ptr<T>* p, memory_order mo); template<class T> void atomic_store(shared_ptr<T>* p, shared_ptr<T> r); template<class T> void atomic_store_explicit(shared_ptr<T>* p, shared_ptr<T> r, memory_order mo); template<class T> shared_ptr<T> atomic_exchange(shared_ptr<T>* p, shared_ptr<T> r); template<class T> shared_ptr<T> atomic_exchange_explicit(shared_ptr<T>* p, shared_ptr<T> r, memory_order mo); template<class T> bool atomic_compare_exchange_weak(shared_ptr<T>* p, shared_ptr<T>* v, shared_ptr<T> w); template<class T> bool atomic_compare_exchange_strong( shared_ptr<T>* p, shared_ptr<T>* v, shared_ptr<T> w); template<class T> bool atomic_compare_exchange_weak_explicit(shared_ptr<T>* p, shared_ptr<T>* v, shared_ptr<T> w, memory_order success, memory_order failure); template<class T> bool atomic_compare_exchange_strong_explicit(shared_ptr<T>* p, shared_ptr<T>* v, shared_ptr<T> w, memory_order success, memory_order failure);struct STNGS { int i; vector<double> v; ting::shared_mutex m; }; STNGS stngs; int myFunction() //called by multiple threads { shared_lock<shared_mutex> _(stngs.m); //do some stuff using stngs return 0; } void updateSettings() { unique_lock<shared_mutex> _(stngs.m); //fill stngs } void initialize() { //fill stngs }struct STNGS { int i; vector<double> v; }; shared_ptr<STNGS> pStng; int myFunction() //called by multiple threads { shared_ptr<STNGS> stngs = atomic_load(&pStng); //do some stuff using *stngs return 0; } void updateSettings() { shared_ptr<STNGS> newStng(new STNGS); //fill *newStng atomic_store(&pStng, newStng); } void initialize() { pStng.reset(new STNGS); //fill *pStng }