🚧 能编译了,makefile还没写

This commit is contained in:
shufeng2012 committed 2026-08-10 11:15:26 +08:00
1 parent 4b7773daec
commit 8fe2afdfde
3 files changed
+26 -8

No files matched your search

View File
Whitespace-only changes.
+1
View File
@@ -38,6 +38,7 @@ private:
size_t __size = 0; size_t __size = 0;
int MAX_TIME = 60 * 10; // 10分钟 int MAX_TIME = 60 * 10; // 10分钟
void flush(); void flush();
void update_queue();
public: public:
+25 -8
View File
@@ -16,21 +16,36 @@ void Memdb <T, U>::flush() {
return; return;
} }
std::chrono::system_clock::time_point now_time = std::chrono::system_clock::now(); std::chrono::system_clock::time_point now_time = std::chrono::system_clock::now();
std::list <memdb_column>::iterator it = this -> time_touch.front().item; typename std::list <memdb_column>::iterator it = this -> time_touch.top().item;
while (now_time > it -> timestamp || it -> be_del == true) { while (now_time > it -> timestamp || it -> be_del == true) {
if (it -> be_del != true) this -> __size--;
key_t to_be_del_k = it -> key;
this -> db.erase(it); this -> db.erase(it);
this -> keys.erase(to_be_del_k);
this -> time_touch.pop(); this -> time_touch.pop();
this -> __size--;
if (this -> time_touch.empty() == true) { if (this -> time_touch.empty() == true) {
return; return;
} }
it = this -> time_touch.front().item; it = this -> time_touch.top().item;
now_time = std::chrono::system_clock::now(); now_time = std::chrono::system_clock::now();
} }
} }
template <typename T, typename U>
void Memdb <T, U>::update_queue() {
std::priority_queue <index_timestamp> new_time_touch;
while (this -> time_touch.empty() == false) {
new_time_touch.push(this -> time_touch.top());
this -> time_touch.pop();
}
this -> time_touch = new_time_touch;
}
template <typename T, typename U> template <typename T, typename U>
Memdb <T, U>::Memdb() = default; Memdb <T, U>::Memdb() = default;
@@ -98,7 +113,7 @@ bool Memdb <T, U>::insert(key_t to_be_ins_k, value_t ins_v) {
Memdb::index_keys new_key; Memdb::index_keys new_key;
new_key.key = to_be_ins_k; new_key.key = to_be_ins_k;
new_key.item = std::prev(this -> db.end()); new_key.item = std::prev(this -> db.end());
this -> keys.insert(new_key); this -> keys[to_be_ins_k] = new_key;
Memdb::index_timestamp new_time_touch; Memdb::index_timestamp new_time_touch;
new_time_touch.item = std::prev(this -> db.end()); new_time_touch.item = std::prev(this -> db.end());
@@ -118,9 +133,10 @@ bool Memdb <T, U>::remove(key_t to_be_del_k) {
return this -> fail; return this -> fail;
} }
std::list <memdb_column>::iterator it = this -> keys[to_be_del_k].item; typename std::list <memdb_column>::iterator it = this -> keys[to_be_del_k].item;
it -> be_del = true; it -> be_del = true;
this -> keys.erase(it -> key); this -> keys.erase(it -> key);
this -> __size--;
return this -> succ; return this -> succ;
} }
@@ -134,11 +150,12 @@ bool Memdb <T, U>::update(key_t to_be_udt_k, value_t udt_v, bool need_to_udt_tim
return this -> fail; return this -> fail;
} }
std::list <memdb_column>::iterator it = this -> keys[to_be_udt_k].item; typename std::list <memdb_column>::iterator it = this -> keys[to_be_udt_k].item;
it -> value = udt_v; it -> value = udt_v;
if (need_to_udt_timetouch == true) { if (need_to_udt_timetouch == true) {
std::chrono::system_clock::time_point now_time = std::chrono::system_clock::now(); std::chrono::system_clock::time_point now_time = std::chrono::system_clock::now();
it -> timestamp = now_time + std::chrono::seconds(MAX_TIME); //! 排序失效 it -> timestamp = now_time + std::chrono::seconds(MAX_TIME);
this -> update_queue();
} }
return this -> succ; return this -> succ;
@@ -153,6 +170,6 @@ std::optional<U> Memdb <T, U>::search(key_t to_be_sch_k){
return std::nullopt; return std::nullopt;
} }
std::list <memdb_column>::iterator it = this -> keys[to_be_sch_k].item; typename std::list <memdb_column>::iterator it = this -> keys[to_be_sch_k].item;
return it -> value; return it -> value;
} }