還是一個很小的模塊。
bio就是background io的意思,既然要background,就要創建線程,創建幾個線程呢?有幾種類型的io,就創建幾個線程。同一種類型的job需要排隊,所以存放各自的工作鏈表里面。
redis目前有兩種類型的job:
一個是close file descriptor,另一個是aof sync。
線程的堆棧默認設為4M,每個線程運行開始時還要把SIG_ALRM(定時器信號)block掉,保證watchdog發出的信號只有主線程接收到。
介紹下接口:
// 初始化bio的結構
void bioInit(void);
// 添加job
void bioCreateBackgroundJob(int type, void *arg1, void *arg2, void *arg3);
// 對于指定類型的bio,當前pending隊列中的job數量是多少
unsigned long long bioPendingJobsOfType(int type);
// 以下兩個接口不再使用,不必關心
void bioWaitPendingJobsLE(int type, unsigned long long num);
time_t bioOlderJobOfType(int type);
看看其中要到的結構和數據:
struct bio_job {
? ? time_t time; // Job創建時間
? ? void *arg1, *arg2, *arg3; ? ?// 執行job需要帶的ca
};
// 涉及多線程,就要考慮同步的問題,這是鎖和條件變量,條件變量用于隊列非空時激活線程去處理
static pthread_mutex_t bio_mutex[REDIS_BIO_NUM_OPS];
static pthread_cond_t bio_condvar[REDIS_BIO_NUM_OPS];
// 任務隊列
static list *bio_jobs[REDIS_BIO_NUM_OPS];
// 這個變量完全是多余,直接就是bio_jobs的鏈表長度
static unsigned long long bio_pending[REDIS_BIO_NUM_OPS];
?
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
