refactor(.gitignore): 更新 .gitignore 文件，忽略所有 .sh 脚本

perf(ThreadPool): 调整线程池默认线程数为硬件并发数

feat(rmdb): 添加函数执行时间计时功能
- 在 rmdb.cpp 中加入 ENABLE_TIMER 宏定义
- 添加 GetFunctionTime 相关代码以进行函数计时

Author: Lin-jingy

.gitignore

@@ -78,4 +78,4 @@ performance_testing/*.folded
 
 .cunzhi-memory/
 
-make.sh
+*.sh

src/common/getFunctionTime.h

@@ -0,0 +1,50 @@
+#pragma once
+
+#include <atomic>
+#include <cstddef>
+#include <chrono>
+#include <iostream>
+
+namespace timedetail {
+
+class TotTime {
+   public:
+    static TotTime& getInstance() {
+        static TotTime instance;
+        return instance;
+    }
+
+    void add(int64_t time) { tot_time.fetch_add(time); }
+
+    int64_t get() { return tot_time; }
+
+    void print() {
+        std::clog << "\033[0m\033[1;31m" << "Total time: " << tot_time.load() / 1e6 << " ms" << "\033[0m" << std::endl;
+    }
+
+   private:
+    std::atomic_int64_t tot_time = 0;
+    TotTime() = default;
+};
+
+}
+
+class GetTime {
+   private:
+    std::chrono::high_resolution_clock::time_point start;
+
+   public:
+    GetTime() { start = std::chrono::high_resolution_clock::now(); }
+    ~GetTime() {
+        auto now = std::chrono::high_resolution_clock::now();
+        auto use = std::chrono::duration_cast<std::chrono::nanoseconds>(now - start).count();
+        timedetail::TotTime::getInstance().add(use);
+    }
+};
+#ifndef AcquisitionTime
+#define AcquisitionTime GetTime();
+#endif
+
+#ifndef PrintFunctionTime
+#define PrintFunctionTime timedetail::TotTime::getInstance().print();
+#endif

src/common/parallel/ThreadPool.h

@@ -37,7 +37,7 @@ class ThreadPool {
     std::condition_variable condition;
 };
 
-inline size_t ThreadPool::thread_num_ = std::max(4u, std::thread::hardware_concurrency() / 2);
+inline size_t ThreadPool::thread_num_ = std::max(4u, std::thread::hardware_concurrency());
 
 inline ThreadPool::ThreadPool(size_t threads) : stop(false) {
     for (size_t i = 0; i < threads; ++i)

src/rmdb.cpp

@@ -35,12 +35,15 @@
 #include "portal.h"
 #include "recovery/log_recovery.h"
 #include "common/utils/Format.h"
+#include "common/getFunctionTime.h"
 
 #define SOCK_PORT 8765
 #define MAX_CONN_LIMIT 8
 
 // 是否开启 std::cout
 constexpr bool ENABLE_COUT = false;
+// 是否输出函数计时结果
+constexpr bool ENABLE_TIMER = true;
 
 // #define ENABLE_SERIALIZE
 
@@ -92,6 +95,9 @@ void sigint_handler(int signo) {
     should_exit = true;
     // log_manager->flush_log_to_disk();
     Print("The Server receive Crtl+C, will been closed\n");
+    if constexpr (ENABLE_TIMER) {
+        PrintFunctionTime
+    }
     longjmp(jmpbuf, 1);
 }