Linux平台上C語言實現非同步佇列的兩種方法

linux上目前有兩種事件通知方式，一種是執行緒條件變數，一種是利用eventfd實現事件通知，下面介紹一下利用這兩種方法實現非同步佇列的方法。

相關函式介紹

喚醒丟失問題

如果執行緒未持有與條件相關聯的互斥鎖，則呼叫 pthread_cond_signal() 或 pthread_cond_broadcast() 會產生喚醒丟失錯誤。滿足以下所有條件時，即會出現喚醒丟失問題：

訊號不起作用，因此將會丟失，僅當修改所測試的條件但未持有與之相關聯的互斥鎖時，才會出現此問題。只要僅在持有關聯的互斥鎖同時修改所測試的條件，即可呼叫 pthread_cond_signal() 和 pthread_cond_broadcast()，而無論這些函式是否持有關聯的互斥鎖。

執行緒條件變數使用方法

get_resources(int amount)    
resources -= amount;
pthread_mutex_unlock(&rsrc_lock);

add_resources(int amount)

int eventfd(unsigned int initval, int flags);

eventfd是linux提供核心態的事件等待/通知機制，核心維護了乙個8位元組的整型數，該整型數由initval來初始化，flags引數可以由以下值位或而來：

當核心維護的8位元組整型數為0時，read操作會阻塞，如果為fd設定為非阻塞模式，則返回eagain錯誤。

下面我們實現乙個簡單的環形佇列：

#define default_size 1024
typedef struct queue
queue_t;
queue_t *queue_create(int size)
else
q->header = q->tail = q->size = 0;
}return q;
}int queue_is_full(queue_t *q)
int queue_is_empty(queue_t *q)
void queue_push_tail(queue_t *q, void *data)
}void *queue_pop_head(queue_t *q)
return data;
}int *queue_free(queue_t *q)

typedef struct async_queue
async_queue_t;
async_queue_t *async_queue_create(int size)
void async_queue_push_tail(async_queue_t *q, void *data)
pthread_mutex_unlock(&(q->mutex));
}}void *async_queue_pop_head(async_queue_t *q, struct timeval *tv)
q->waiting_threads--;
}retval = queue_pop_head(q->_queue);
pthread_mutex_unlock(&(q->mutex));
return retval;
}void async_queue_free(async_queue_t *q)

typedef struct async_queue
async_queue_t;
async_queue_t *async_queue_create(int size)
void async_queue_push_tail(async_queue_t *q, void *data)
}void *async_queue_pop_head(async_queue_t *q, struct timeval *tv)
else
}void async_queue_free(async_queue_t *q)

兩種實現方法執行緒條件變數比較複雜，但是效能略高，而eventfd實現簡單，但是效能略低。

Linux平台上C語言實現非同步佇列的兩種方法

Linux平台上用C 實現多執行緒互斥鎖

Linux平台上用C 實現多執行緒互斥鎖

在Symbian OS平台上移植C語言工程的方法

Linux平台上C語言實現非同步佇列的兩種方法

Linux平台上用C 實現多執行緒互斥鎖

Linux平台上用C 實現多執行緒互斥鎖

在Symbian OS平台上移植C語言工程的方法

相關推薦