zhangmeng
2024-01-18 f68d32c9f4b2f46d26d96839801d1888a93f93ed
src/shm/hashtable.h
@@ -5,15 +5,23 @@
#include <functional>
#include <set>
#define MAPSIZE 100
#define START_KEY 1000
#define MAPSIZE 4096
// 创建Queue数量的上限
#define QUEUE_COUNT_LIMIT 300
typedef struct hashtable_t
{
 struct tailq_header_t* array[MAPSIZE];
 int mutex;
 int queueCount;
 int currentKey; // 当前分配的key
 // int wlock;
 // int cond;
 // size_t readcnt;
} hashtable_t;
typedef void (*hashtable_foreach_cb)(int key, void *value);
@@ -21,14 +29,17 @@
void hashtable_init(hashtable_t *hashtable);
void hashtable_destroy(hashtable_t *hashtable);
void *hashtable_get(hashtable_t *hashtable, int key);
void hashtable_put(hashtable_t *hashtable, int key, void *value);
void *hashtable_remove(hashtable_t *hashtable, int key);
void hashtable_removeall(hashtable_t *hashtable);
void hashtable_put(hashtable_t *hashtable, int key, void *value) ;
bool  hashtable_check_put(hashtable_t *hashtable, int key, void *value, bool overwrite) ;
static inline void _hashtable_remove(hashtable_t *hashtable, int key);
void hashtable_remove(hashtable_t *hashtable, int key);
void hashtable_removeall(hashtable_t *hashtable);
int hashtable_get_queue_count(hashtable_t *hashtable) ;
/** 
 * 遍历hash_table
 * @demo 
 * hashtable_foreach(&hashtable, [&](int key, void * value){
 * hashtable_foreach(hashtable, [&](int key, void * value){
 *   printf("%d, %p\n", key, value);
 * });
 *