为多个会话保留XPtr



我有一个R函数,它创建一个PrimebaseCpp类,然后返回一个XPtr<Primebase>指针。

由于构建过程需要大量时间,我想将Primebase的实例保存到会话中,以便下次打开R时可以直接访问Primebase实例。

不幸的是,一旦我关闭R,底层对象就会被删除,XPtr变成null pointer

有没有一种方法可以防止R删除对象或任何其他方法来保存底层对象?

当R会话结束时,由Rcpp::Xptr管理的C++对象将被销毁。如果你想保存对象,你必须序列化它。Rcereal包提供了一个很好的可能性。以下示例使用一个在构造函数中具有人工睡眠的平凡Primebase类来模拟构建过程中的繁重处理。在检查对象的内容之后,它被序列化并销毁。然后,该对象被反序列化并再次封装到Xptr中。请注意,反序列化比构造便宜得多:

#include <Rcpp.h>
// [[Rcpp::plugins("cpp11")]]
// [[Rcpp::depends(Rcereal)]]
#include <cereal/archives/binary.hpp>
#include <chrono>
#include <fstream>
#include <thread>
class Primebase
{
private:
int x;
public:
Primebase() : x{0} {};
Primebase(int x_) : x{x_} {std::this_thread::sleep_for(std::chrono::seconds(1));};
int answer() {return x;}
template <class Archive>
void serialize(Archive & ar)
{
ar(x);
}
};
// [[Rcpp::export]]
Rcpp::XPtr<Primebase> create(int x) {
Primebase* instance = new Primebase(x);
return Rcpp::XPtr<Primebase>(instance);
}

// [[Rcpp::export]]
int answer(Rcpp::XPtr<Primebase> xptr) {
return xptr.get()->answer();
}
// [[Rcpp::export]]
void mySerialize(Rcpp::XPtr<Primebase> xptr, std::string filename) {
std::ofstream os(filename, std::ios::binary);
cereal::BinaryOutputArchive archive(os);
archive(*xptr.get());
}
// [[Rcpp::export]]
Rcpp::XPtr<Primebase> myDeserialize(std::string filename) {
std::ifstream is(filename, std::ios::binary);
cereal::BinaryInputArchive archive(is);
Primebase* instance = new Primebase;
archive(*instance);
return Rcpp::XPtr<Primebase>(instance);
}

/*** R
system.time(xptr <- create(42))
answer(xptr)
mySerialize(xptr, "test.cereal")
rm(xptr)
exists("xptr")
system.time(xptr <-myDeserialize("test.cereal")) 
answer(xptr)
*/

输出:

> system.time(xptr <- create(42))
user  system elapsed 
0.000   0.000   1.001 
> answer(xptr)
[1] 42
> mySerialize(xptr, "test.cereal")
> rm(xptr)
> exists("xptr")
[1] FALSE
> system.time(xptr <-myDeserialize("test.cereal")) 
user  system elapsed 
0       0       0 
> answer(xptr)
[1] 42

参考文献:

  • 谷物文档
  • 钢筋混凝土墙廊

最新更新