各種通信機制使用舉例

linux內(nèi)核的 等待隊列 使用方法，wait_queue_head_t，進程休眠 (2011-11-28 09:29:44)轉(zhuǎn)載▼

標簽： linux內(nèi)核驅(qū)動 雜談 分類： LINUX內(nèi)核

當你在用戶空間需要讀寫一大片數(shù)據(jù)的時候，這個就用上了。

 

 

 

假設(shè)我們在 kernel 里產(chǎn)生一個 buffer，user 可以經(jīng)由 read，write 等 system call 來讀取或?qū)戀Y料到這個 buffer 里。如果有一個 user 寫資料到 buffer 時，此時 buffer 已經(jīng)滿了。那請問你要如何去處理這種情形呢 ? 第一種，傳給 user 一個錯誤訊息，說 buffer 已經(jīng)滿了，不能再寫入。第二種，將 user 的要求 block 住， 等有人將 buffer 內(nèi)容讀走，留出空位時，再讓 user 寫入資料。但問題來了，你要怎么將 user 的要求 block 住。難道你要用

while ( is_full );

write_to_buffer;

這 樣的程序代碼嗎? 想想看，如果你這樣做會發(fā)生什么事? 第一，kernel會一直在這個 while 里執(zhí)行。第二個，如果 kernel 一直在這個 while 里執(zhí)行，表示它沒有辦法去 maintain系統(tǒng)的運作。那此時系統(tǒng)就相當于當?shù)袅�。在這里 is_full 是一個變量，當然，你可以讓 is_full 是一個 function，在這個 function里會去做別的事讓 kernel 可以運作，那系統(tǒng)就不會當。這是一個方式。還有,你說可以在while里面把buffer里的內(nèi)容讀走,再把is_full的值改了,但是我們會可能把重 要的數(shù)據(jù)在我們不想被讀的時候被讀走了,那是比較麻煩的,而且很不靈活.如果我們使用 wait_queue 的話，那程序看起來會比較漂亮，而且也比較讓人了解，如下所示:

 

struct wait_queue_head_t wq;

DECLARE_WAIT_QUEUE_HEAD (wq);

 

while ( is_full ){

interruptible_sleep_on( &wq );

} write_to_buffer();

 

interruptible_sleep_on( &wq ) 是用來將目前的 process，也就是要求寫資料到buffer 的 process放到 wq 這個 wait_queue 里。在 interruptible_sleep_on 里，則是最后會呼叫 schedule() 來做 schedule 的動作,誰調(diào)用了schedule誰就趴下,讓別人去運行,醒來就原地起來，執(zhí)行schedule()后的代碼。那那個調(diào)用了schedule的家伙什么 醒過來呢?這時候就需要用到另一個函數(shù)了wake_up_interruptible()了。

以下來自：http://tauruspdj.blog.163.com/blog/static/4312500620090794030998/

linux中最簡單的休眠方式是下面的宏，

wait_event(queue, condition)

wait_event_interruptible(queue, condition)

wait_event_timeout(queue, condition, timeout)

wait_event_interruptible_timeout(queue, condition, timeout)

queue是等待隊列頭，傳值方式

condition是任意一個布爾表達式，在休眠前后多次對condition求值，為真則喚醒

喚醒進程的基本函數(shù)是wake_up

void wake_up(wait_queue_head_t *queue);

void wake_up_interruptible(wait_queue_head_t *queue);

實踐中，一般是wait_event和 wake_up， wait_event_interruptible和 wake_up_interruptible 成對使用。

【補充】其實看了那么多，他們也沒有給個立即可用的步驟，寫blog嘛，就是分享心得。我基于2.6.24總結(jié)一下，希望對大家有幫助：

1、定義：wait_queue_head_t my_queue;

2、初始化 init_waitqueue_head(&my_queue)；

3、在一個函數(shù)里面等待：wait_event(queue, condition) ;（別在中斷里面搞）

 

4、在另一個函數(shù)里面喚醒：wake_up(wait_queue_head_t *queue); (這個可以在中斷調(diào)用，去喚醒別的進程，特別是dma操作類的）

 

有好幾個等待和喚醒函數(shù)，大家可以慢慢試。