還是一個很小的模塊。

bio就是background io的意思，既然要background,就要創(chuàng)建線程，創(chuàng)建幾個線程呢?有幾種類型的io,就創(chuàng)建幾個線程。同一種類型的job需要排隊，所以存放各自的工作鏈表里面。

redis目前有兩種類型的job:

一個是close file descriptor,另一個是aof sync。

線程的堆棧默認(rèn)設(shè)為4M，每個線程運行開始時還要把SIG_ALRM(定時器信號)block掉，保證watchdog發(fā)出的信號只有主線程接收到。

介紹下接口:

// 初始化bio的結(jié)構(gòu)

void bioInit(void);

// 添加job
void bioCreateBackgroundJob(int type, void *arg1, void *arg2, void *arg3);

// 對于指定類型的bio,當(dāng)前pending隊列中的job數(shù)量是多少
unsigned long long bioPendingJobsOfType(int type);

// 以下兩個接口不再使用，不必關(guān)心
void bioWaitPendingJobsLE(int type, unsigned long long num);
time_t bioOlderJobOfType(int type);

看看其中要到的結(jié)構(gòu)和數(shù)據(jù):

struct bio_job {
? ? time_t time; // Job創(chuàng)建時間
? ? void *arg1, *arg2, *arg3; ? ?// 執(zhí)行job需要帶的ca
};

// 涉及多線程，就要考慮同步的問題，這是鎖和條件變量,條件變量用于隊列非空時激活線程去處理

static pthread_mutex_t bio_mutex[REDIS_BIO_NUM_OPS];
static pthread_cond_t bio_condvar[REDIS_BIO_NUM_OPS];

// 任務(wù)隊列
static list *bio_jobs[REDIS_BIO_NUM_OPS];

// 這個變量完全是多余，直接就是bio_jobs的鏈表長度

static unsigned long long bio_pending[REDIS_BIO_NUM_OPS];

?

Redis bio