#include #include #include #include #include"../basic/nanxing_operator_check.h" namespace nanxing_extend { //这是个意外,本来是想工厂类和不同的过滤器划分到不同文件的,但是由于贯彻head_only,还没想出来怎么组织文件,只能丢在一起了 //同时也是一个控制类,即这个类本身带有控制功能,只允许一次产生持有唯一的filter //如果不对产生的类进行管控,最后的结果很可能是完全无法处理,因为C++中内存分配方式过于多样,malloc,new,new[],数组。。。。乱七八糟,最后类内生成的空间完全无法析构,因为根本不知道类内怎么实现的 //当然也可以通过返回智能指针的方式进行管控,但是没有选择那么做的原因在于过滤器本身不会大量存在 //一个程序中最多一到两个过滤器 //但是但是相信我不会有God class template class FilterPolicy { static_assert(NANXING_BASIC_OPERATOR_(K,compare),"the type of key cannot compare"); private: FilterPolicy& operator=(FilterPolicy const&)=delete; FilterPolicy(FilterPolicy const&)=delete; FilterPolicy* producter=nullptr; //用于管控生成的类 public: //限制当主动生成一个工厂类后,不管怎么赋值,最后只有一个工厂 //move-only FilterPolicy(){}; FilterPolicy(FilterPolicy&&){} virtual void policy_print(){producter->policy_print();} //输出对应的计算公式 virtual void parameter_print(){producter->parameter_print();} //输出过滤器的参数 //两个工厂函数用于生成不同的过滤器 FilterPolicy* creat_Bloomfilter(int N,int P); FilterPolicy* creat_Cuckoofilter(); virtual void init_filter(){producter->init_filter();} virtual ~FilterPolicy(){}; }; template class bloomfilter:public FilterPolicy { static_assert(NANXING_BASIC_OPERATOR_(K,compare),"the type of key cannot compare"); private: //这里使用线性混合同余来构造哈希函数,因为线性混合同余的随机性和运算效率的平衡比较好 constexpr static const int hash_prime_number1[10]={52223,52237,79939,19937,8243,24133,12647,13147,62459,94547}; //给出10个大素数作为哈希函数的素数种子 constexpr static const int hash_prime_number2[10]={94399,94421,94427,94433,94439,94441,94447,94463,94477,94483}; //哈希函数的置偏值 struct param{ float P; //概率参数 int k; //哈希函数个数 int n; //n数据长度 int m; //bloomfilter长度 param(float _p,int _n):P(_p),n(_n){} }; private: u_int64_t* bitarray; //bloomfilter的核心数据结构,一个比特数组 param parameter; protected: bloomfilter()=delete; bloomfilter(bloomfilter&)=delete; bloomfilter& operator=(bloomfilter)=delete; //不允许复制构造 void caculater()noexcept //计算bloomfilter的参数 { parameter.m=static_cast(-(parameter.n*std::log(parameter.P)/0.4804530139)); parameter.k=static_cast(0.6931471806*(parameter.m/parameter.n)); } int hash_function(int i,K data) //i代表第i个哈希函数,返回在bloomfilter中的位置 { return ((static_cast(data))*(this->hash_prime_number1[i])+(this->hash_prime_number2[i]))%(this->parameter.m); } public: bloomfilter(float _p,int _n):bitarray(0),parameter(_p,_n){} void init_filter()override{ caculater(); bitarray=new u_int64_t[static_cast(parameter.m/64)+1]; //构建数组 std::memset(bitarray,0,sizeof(u_int64_t)*static_cast(parameter.m/64)+1); //初始化 } void policy_print()override //打印出使用的公式 { std::cout<<"m=-((nlnP)/((ln2)^2))"<<"//m为bloomfilter的长度"< class Cuckoofilter:public FilterPolicy { static_assert(NANXING_BASIC_OPERATOR_(K,compare),"the type of key cannot compare"); }; template FilterPolicy* FilterPolicy::creat_Bloomfilter(int N,int P) { if(producter!=nullptr) { delete producter; } producter=new bloomfilter(N,P); return producter; } template FilterPolicy* FilterPolicy::creat_Cuckoofilter() { if(producter!=nullptr) { delete producter; } producter=new Cuckoofilter; return producter; } }