簡(jiǎn)介本資源是一份面向操作系統(tǒng)課程學(xué)習(xí)者與C/C多線程編程初學(xué)者的實(shí)踐型實(shí)驗(yàn)材料聚焦進(jìn)程間同步與互斥核心機(jī)制在真實(shí)場(chǎng)景中的落地——以銀行柜員服務(wù)系統(tǒng)為模型完整實(shí)現(xiàn)顧客取號(hào)、柜員叫號(hào)、隊(duì)列等待、信號(hào)量協(xié)調(diào)P/V操作及線程安全控制。資源以PDF文檔形式呈現(xiàn)共1個(gè)文件370KB內(nèi)容涵蓋實(shí)驗(yàn)題目要求、設(shè)計(jì)思路、偽代碼算法、C11線程與pthread互斥鎖/信號(hào)量的具體實(shí)現(xiàn)細(xì)節(jié)、測(cè)試數(shù)據(jù)格式說(shuō)明及標(biāo)準(zhǔn)輸出規(guī)范并附有結(jié)構(gòu)體定義、關(guān)鍵函數(shù)分析與整體架構(gòu)圖。已有1873人學(xué)習(xí)下載適合高校學(xué)生完成操作系統(tǒng)課程實(shí)驗(yàn)、理解Dijkstra信號(hào)量原理、掌握Linux環(huán)境下多線程并發(fā)編程與資源競(jìng)爭(zhēng)控制方法是理論結(jié)合實(shí)踐的典型教學(xué)案例。1. 銀行柜員服務(wù)模擬一個(gè)能跑通、能 debug、能改出新調(diào)度策略的 POSIX 線程實(shí)戰(zhàn)項(xiàng)目你有沒(méi)有試過(guò)在 Linux 下寫(xiě)一個(gè)多線程程序編譯通過(guò)、運(yùn)行不崩但輸出時(shí)間戳亂序、顧客被重復(fù)服務(wù)、甚至兩個(gè)柜員同時(shí)叫了同一個(gè)號(hào)這不是玄學(xué)——這是信號(hào)量和互斥鎖沒(méi)對(duì)齊的真實(shí)現(xiàn)場(chǎng)。這個(gè)「銀行柜員服務(wù)問(wèn)題」項(xiàng)目就是專治這類多線程血淚經(jīng)驗(yàn)的硬核練手工程它用最樸素的pthreadsem_tpthread_mutex_t在 Ubuntu 18.04 上完整復(fù)現(xiàn)了操作系統(tǒng)課里那個(gè)經(jīng)典同步模型——n 個(gè)柜員、m 個(gè)顧客、取號(hào)排隊(duì)、叫號(hào)服務(wù)、空閑等待、服務(wù)阻塞全部靠 P/V 操作驅(qū)動(dòng)。它不是玩具 demo而是帶真實(shí)輸入文件解析、帶秒級(jí)時(shí)間模擬、帶結(jié)構(gòu)化輸出到達(dá)/開(kāi)始/離開(kāi)/柜員號(hào)、帶線程生命周期管理顧客線程退出、柜員線程可取消的完整閉環(huán)。適合剛學(xué)完信號(hào)量理論、正卡在「知道概念但寫(xiě)不出正確代碼」階段的開(kāi)發(fā)者也適合想快速驗(yàn)證自己對(duì)sem_wait/sem_post時(shí)序理解是否到位的熟手——因?yàn)樗倪壿嬜銐蚯逦e(cuò)誤足夠典型改一行就能看到效果。別被“課程實(shí)驗(yàn)”四個(gè)字勸退這項(xiàng)目落地性極強(qiáng)把sleep()換成真實(shí) I/O、把queueCustomer*換成共享內(nèi)存隊(duì)列、把柜員線程改成工作竊取模式……它就是你調(diào)試線程競(jìng)爭(zhēng)、壓測(cè)鎖粒度、驗(yàn)證調(diào)度策略的第一塊真實(shí)磚。2. 架構(gòu)與模塊拆解從 main() 到 customer_thread() 的五層控制流這個(gè)項(xiàng)目表面看是“顧客取號(hào)、柜員叫號(hào)”實(shí)則暗含五層協(xié)同時(shí)間驅(qū)動(dòng)層 → 輸入解析層 → 線程管理層 → 同步原語(yǔ)層 → 數(shù)據(jù)結(jié)構(gòu)層。每一層都不可省略且錯(cuò)誤常藏在層間交接處。下面按實(shí)際執(zhí)行順序逐層拆解重點(diǎn)講清每個(gè)模塊為什么這么設(shè)計(jì)、關(guān)鍵變量怎么協(xié)作、以及它們?cè)谧罱K輸出中如何映射。2.1 主控流程main() 中的初始化與線程生命周期編排main()函數(shù)是整個(gè)系統(tǒng)的指揮中樞它不處理業(yè)務(wù)邏輯但決定了所有線程何時(shí)啟動(dòng)、如何等待、何時(shí)收尾。核心動(dòng)作只有四步但每一步都踩著同步安全的邊界int main(int argc, char *argv[]) { // 1. 初始化全局資源互斥鎖、信號(hào)量、隊(duì)列、時(shí)間基準(zhǔn) pthread_mutex_init(mutex, NULL); sem_init(customer_sem, 0, 0); // 初始無(wú)顧客等待 sem_init(counter_sem, 0, COUNTER_NUM); // 初始所有柜員空閑 time(program_start_time); // 2. 解析輸入文件構(gòu)建 customer_list 和 counter_list parse_input_file(input.txt); // 3. 創(chuàng)建線程先顧客后柜員順序很重要 for (auto c : customer_list) { pthread_create(c.pID, NULL, customer_thread, c); } for (auto cnt : counter_list) { pthread_create(cnt.pID, NULL, counter_thread, cnt); } // 4. 等待所有顧客完成 清理柜員線程 輸出結(jié)果 for (auto c : customer_list) { pthread_join(c.pID, NULL); // 必須等顧客線程自然結(jié)束 } for (auto cnt : counter_list) { pthread_cancel(cnt.pID); // 主動(dòng)取消柜員線程 pthread_join(cnt.pID, NULL); } write_output_file(output.txt); cleanup_resources(); return 0; }關(guān)鍵參數(shù)說(shuō)明sem_init(customer_sem, 0, 0)第二個(gè)參數(shù)0表示該信號(hào)量不跨進(jìn)程共享僅本進(jìn)程內(nèi)線程可見(jiàn)第三個(gè)參數(shù)0是初始值——意味著程序啟動(dòng)時(shí)沒(méi)有顧客在等待隊(duì)列中柜員線程首次sem_wait(customer_sem)會(huì)立即阻塞。sem_init(counter_sem, 0, COUNTER_NUM)初始值設(shè)為柜員總數(shù)代表初始空閑柜員數(shù)。每當(dāng)一個(gè)顧客被叫號(hào)就sem_post(counter_sem)通知下一個(gè)顧客“有柜員可用”。pthread_join(c.pID, NULL)vspthread_cancel(cnt.pID)顧客線程是自然終止型服務(wù)完就 return必須join等待其結(jié)束柜員線程是長(zhǎng)周期運(yùn)行型while true需用cancel主動(dòng)中斷且中斷點(diǎn)必須在pthread_testcancel()處——這正是代碼里pthread_setcancelstate(..., PTHREAD_CANCEL_ENABLE)的作用。2.2 輸入解析層從 input.txt 到 vector 的結(jié)構(gòu)化建模測(cè)試數(shù)據(jù)格式極其簡(jiǎn)單id arrive_time service_duration但解析邏輯直接影響后續(xù)線程行為的真實(shí)性。項(xiàng)目沒(méi)有用fscanf硬讀而是封裝了健壯的parse_input_file()它做了三件事按行讀取并校驗(yàn)字段數(shù)跳過(guò)空行、注釋行對(duì)每行sscanf(line, %d %d %d, id, arrive, dur)失敗則報(bào)錯(cuò)退出構(gòu)造 Customer 對(duì)象并 push 到 vectorcustomer_list.emplace_back(id, arrive, dur)注意arrive_time是相對(duì)時(shí)間單位秒用于sleep(arrive_time)模擬顧客到達(dá)時(shí)刻預(yù)分配內(nèi)存并記錄總數(shù)customer_list.reserve(expected_count)避免 vector 動(dòng)態(tài)擴(kuò)容導(dǎo)致的指針失效這點(diǎn)對(duì)后續(xù)queueCustomer*安全至關(guān)重要。為什么用vectorCustomer而不是vectorunique_ptrCustomer因?yàn)樗蓄櫩途€程都持有Customer引用void* arg轉(zhuǎn)換而來(lái)而vector在push_back時(shí)若觸發(fā) realloc原有元素地址會(huì)變導(dǎo)致線程訪問(wèn)野指針。項(xiàng)目選擇在解析完成后不再增刪 customer_list并確保customer_list生命周期長(zhǎng)于所有線程從而規(guī)避此風(fēng)險(xiǎn)。這是 C 多線程中典型的“對(duì)象生命周期管理”陷阱新手極易翻車(chē)。2.3 線程管理層顧客線程與柜員線程的職責(zé)分離與協(xié)作契約項(xiàng)目將并發(fā)邏輯嚴(yán)格劃分為兩類線程各自承擔(dān)明確角色并通過(guò)信號(hào)量建立雙向契約線程類型啟動(dòng)時(shí)機(jī)終止條件核心職責(zé)依賴的同步原語(yǔ)顧客線程main()中pthread_createreturn NULL服務(wù)完成模擬到達(dá) → 取號(hào)入隊(duì) → 等待叫號(hào) → 接受服務(wù)mutex保護(hù)隊(duì)列、customer_sem通知柜員、counter_sem等待柜員柜員線程main()中pthread_createpthread_cancel()被主控取消等待顧客 → 叫號(hào)出隊(duì) → 服務(wù)顧客 → 釋放柜員mutex保護(hù)隊(duì)列/顧客狀態(tài)、customer_sem等待顧客、counter_sem通知顧客這個(gè)契約的關(guān)鍵在于顧客線程只負(fù)責(zé)“發(fā)布需求”柜員線程只負(fù)責(zé)“響應(yīng)需求”。沒(méi)有一個(gè)線程既管入隊(duì)又管出隊(duì)徹底避免了單點(diǎn)邏輯復(fù)雜化。而customer_sem和counter_sem就是這個(gè)契約的“電子合同”——customer_sem的值 當(dāng)前等待隊(duì)列長(zhǎng)度counter_sem的值 當(dāng)前空閑柜員數(shù)。任何一方修改狀態(tài)都必須通過(guò)sem_post/sem_wait原子更新其他線程才能感知。2.4 同步原語(yǔ)層mutex、customer_sem、counter_sem 的三位一體防御項(xiàng)目用三個(gè)同步機(jī)制構(gòu)成防御體系各司其職缺一不可pthread_mutex_t mutex保護(hù)臨界區(qū)數(shù)據(jù)。哪些算臨界區(qū)?customer_waiting.push(c)/customer_waiting.front()/customer_waiting.pop()—— 隊(duì)列操作本身非原子?cout ...—— 標(biāo)準(zhǔn)輸出流是共享資源多線程混寫(xiě)會(huì)亂碼?customer.counter_id cnt.id/customer.service_start ...—— 修改顧客狀態(tài)需保證原子性。?sleep()、sem_wait()、sem_post()—— 這些函數(shù)本身是線程安全的無(wú)需加鎖。sem_t customer_sem實(shí)現(xiàn)顧客到柜員的單向通知。顧客線程sem_post(customer_sem)后柜員線程sem_wait(customer_sem)才能喚醒。它不保護(hù)數(shù)據(jù)只傳遞“有活干了”的事件信號(hào)。初始值0保證柜員不會(huì)在無(wú)顧客時(shí)瞎忙。sem_t counter_sem實(shí)現(xiàn)柜員到顧客的單向通知。柜員線程sem_post(counter_sem)后顧客線程sem_wait(counter_sem)才能繼續(xù)。它解決的是“顧客取號(hào)后如何知道哪個(gè)柜員空閑了”的問(wèn)題。初始值COUNTER_NUM讓所有顧客上線就能立刻競(jìng)爭(zhēng)柜員。為什么不用一個(gè)信號(hào)量搞定因?yàn)閏ustomer_sem和counter_sem控制的是不同方向的依賴關(guān)系前者是“柜員等待顧客”后者是“顧客等待柜員”。如果強(qiáng)行合并比如用sem_t queue_sem表示隊(duì)列長(zhǎng)度那么當(dāng)隊(duì)列為空時(shí)柜員sem_wait(queue_sem)會(huì)阻塞但顧客sem_post(queue_sem)后柜員喚醒卻無(wú)法知道“現(xiàn)在有幾個(gè)柜員空閑”仍需額外機(jī)制協(xié)調(diào)。雙信號(hào)量設(shè)計(jì)讓責(zé)任邊界清晰是 Dijkstra 原始思想的忠實(shí)實(shí)踐。2.5 數(shù)據(jù)結(jié)構(gòu)層queueCustomer* 與 vector 的內(nèi)存布局真相項(xiàng)目用std::queueCustomer* customer_waiting存儲(chǔ)等待顧客而非queueCustomer這是經(jīng)過(guò)深思熟慮的// 正確存儲(chǔ)指針指向 vector 中已分配的對(duì)象 std::queueCustomer* customer_waiting; // 錯(cuò)誤存儲(chǔ)對(duì)象副本會(huì)導(dǎo)致 service_start 等狀態(tài)修改不生效 // std::queueCustomer customer_waiting;原因在于customer_thread和counter_thread都需要修改同一個(gè)Customer實(shí)例的狀態(tài)如service_start,counter_id。如果queue存的是對(duì)象副本柜員線程修改的是副本顧客線程看到的仍是原始未修改對(duì)象輸出必然錯(cuò)亂。而queueCustomer*存的是指針?biāo)芯€程操作的都是customer_list中同一塊內(nèi)存。內(nèi)存布局圖示簡(jiǎn)化customer_list: [Customer{id1,...}] [Customer{id2,...}] [Customer{id3,...}] ↑地址A ↑地址B ↑地址C customer_waiting: [ptr→A] → [ptr→B] → [ptr→C]柜員線程Customer c *customer_waiting.front()得到的是地址A處的引用修改c.service_start即直接改寫(xiě)了customer_list[0]的字段。這種設(shè)計(jì)犧牲了一點(diǎn)安全性需確保指針不懸空但換來(lái)了狀態(tài)一致性是系統(tǒng)編程中的常見(jiàn)權(quán)衡。3. 核心線程函數(shù)逐行解析customer_thread 與 counter_thread 的執(zhí)行鏈路現(xiàn)在我們深入到最核心的兩段代碼——customer_thread()和counter_thread()。它們不是孤立函數(shù)而是構(gòu)成一個(gè)請(qǐng)求-響應(yīng)閉環(huán)的兩個(gè)齒輪。下面逐行拆解標(biāo)注每行代碼的目的、副作用、潛在風(fēng)險(xiǎn)并解釋為何必須按此順序執(zhí)行。3.1 顧客線程從 sleep 到 return 的七步閉環(huán)void *customer_thread(void *arg) { Customer customer *(Customer *) arg; // 1. 獲取引用避免拷貝 sleep(customer.arrive_time); // 2. 【時(shí)間模擬】阻塞至顧客到達(dá)時(shí)刻 // 注意此處 sleep 不在 mutex 內(nèi)避免阻塞其他顧客取號(hào) pthread_mutex_lock(mutex); // 3. 【臨界區(qū)開(kāi)始】保護(hù)隊(duì)列操作 cout [CUSTOMER] id customer.id arrive at time(NULL) - program_start_time endl; customer_waiting.push(customer); // 4. 【入隊(duì)】將自身地址加入等待隊(duì)列 sem_post(customer_sem); // 5. 【發(fā)信號(hào)】通知柜員“有新顧客了” pthread_mutex_unlock(mutex); // 6. 【臨界區(qū)結(jié)束】釋放鎖允許其他線程操作隊(duì)列 sem_wait(counter_sem); // 7. 【等待響應(yīng)】阻塞直到被某個(gè)柜員叫號(hào) // 此時(shí) customer.service_start 和 counter_id 已被柜員線程設(shè)置 pthread_mutex_lock(mutex); // 8. 【臨界區(qū)再進(jìn)入】保護(hù)輸出 cout [CUSTOMER] id customer.id served by customer.counter_id at customer.service_start . Now time : time(NULL) - program_start_time endl; pthread_mutex_unlock(mutex); // 9. 【臨界區(qū)結(jié)束】 sleep(customer.service_duration); // 10. 【服務(wù)耗時(shí)】模擬服務(wù)過(guò)程此時(shí)顧客已綁定柜員 return NULL; // 11. 【線程終止】顧客服務(wù)完成線程退出 }關(guān)鍵邏輯鏈路說(shuō)明步驟 2 (sleep) 必須在鎖外如果把它放在pthread_mutex_lock之后那么第一個(gè)顧客到達(dá)時(shí)會(huì)獨(dú)占 mutex 長(zhǎng)達(dá)arrive_time秒后續(xù)顧客無(wú)法取號(hào)徹底破壞并發(fā)性。步驟 4 (push) 和步驟 5 (sem_post) 必須在同一個(gè)臨界區(qū)內(nèi)否則可能出現(xiàn)“柜員看到信號(hào)但隊(duì)列為空”的競(jìng)態(tài)顧客剛post信號(hào)還沒(méi)來(lái)得及push柜員就wait成功并front()了。步驟 7 (sem_wait) 是顧客線程的“分水嶺”之前它主動(dòng)推進(jìn)取號(hào)之后它被動(dòng)等待被叫號(hào)。sem_wait返回時(shí)意味著柜員線程已完成customer.service_start和customer.counter_id的賦值因此步驟 8 的輸出必然是最新?tīng)顟B(tài)。3.2 柜員線程while(true) 中的原子叫號(hào)與服務(wù)循環(huán)void *counter_thread(void *arg) { Counter counter *(Counter *) arg; while (true) { sem_wait(customer_sem); // 1. 【等待需求】阻塞直到有顧客入隊(duì) // 此時(shí) customer_sem 值減1表示一個(gè)顧客被認(rèn)領(lǐng) pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL); // 2. 【防中斷】禁止在此刻被 cancel // 因?yàn)榻酉聛?lái)要修改共享狀態(tài)必須原子完成 pthread_mutex_lock(mutex); // 3. 【臨界區(qū)開(kāi)始】保護(hù)隊(duì)列和顧客狀態(tài) Customer customer *customer_waiting.front(); // 4. 【取號(hào)】獲取隊(duì)首顧客引用 customer.counter_id counter.id; // 5. 【綁定】記錄服務(wù)柜員號(hào) customer.service_start time(NULL) - program_start_time; // 6. 【打時(shí)間戳】記錄開(kāi)始服務(wù)時(shí)刻 cout [COUNTER] id counter.id serve customer customer.id at customer.service_start . Now time : time(NULL) - program_start_time endl; customer_waiting.pop(); // 7. 【出隊(duì)】移除已服務(wù)顧客 sem_post(counter_sem); // 8. 【發(fā)信號(hào)】通知顧客“我空閑了輪到你了” pthread_mutex_unlock(mutex); // 9. 【臨界區(qū)結(jié)束】 sleep(customer.service_duration); // 10. 【服務(wù)耗時(shí)】模擬服務(wù)過(guò)程此時(shí)顧客已綁定 pthread_mutex_lock(mutex); // 11. 【臨界區(qū)再進(jìn)入】保護(hù)輸出 cout [COUNTER] id counter.id finish serving customer customer.id at time(NULL) - program_start_time endl; pthread_mutex_unlock(mutex); // 12. 【臨界區(qū)結(jié)束】 pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL); // 13. 【恢復(fù)中斷】允許被 cancel pthread_testcancel(); // 14. 【檢查點(diǎn)】若收到 cancel 請(qǐng)求則在此處退出 } return NULL; // 理論上不會(huì)執(zhí)行到這里 }關(guān)鍵設(shè)計(jì)意圖解析步驟 2 和步驟 13 的pthread_setcancelstate是靈魂柜員線程在pop()和sem_post(counter_sem)之間處于“半服務(wù)”狀態(tài)——顧客已出隊(duì)、柜員已承諾服務(wù)但服務(wù)尚未開(kāi)始。如果此時(shí)被cancel顧客將永遠(yuǎn)丟失隊(duì)列里沒(méi)了柜員也沒(méi)服務(wù)。所以必須禁用 cancel等sem_post發(fā)出信號(hào)、顧客線程sem_wait返回后再恢復(fù) cancel 能力。步驟 8 (sem_post(counter_sem)) 的位置很講究它必須在pthread_mutex_unlock(mutex)之前執(zhí)行。因?yàn)閟em_post是原子操作而unlock后其他線程可能立即搶到 mutex 并修改隊(duì)列。如果sem_post放在unlock之后可能出現(xiàn)“柜員解鎖 → 其他柜員搶鎖 → 發(fā)現(xiàn)隊(duì)列空 → 自己sem_wait阻塞 → 本柜員才sem_post”的延遲導(dǎo)致顧客多等一輪。步驟 4 的Customer customer *customer_waiting.front()是安全的因?yàn)閒ront()返回的是隊(duì)首元素的引用而customer_waiting存的是指針*ptr解引用得到的就是customer_list中原始對(duì)象的引用修改它直接影響最終輸出。4. 編譯、運(yùn)行與避坑指南Ubuntu 18.04 下的實(shí)操排雷手冊(cè)這個(gè)項(xiàng)目在 Ubuntu 18.04.5 LTS 上編譯運(yùn)行看似簡(jiǎn)單g -stdc11 -lpthread但實(shí)際踩坑率極高。很多同學(xué)卡在“編譯成功但輸出亂碼/死鎖/段錯(cuò)誤”根本原因是忽略了 Linux 線程庫(kù)的隱式約束和 g 的默認(rèn)行為。以下是我在某高校實(shí)驗(yàn)室?guī)W(xué)生調(diào)試時(shí)整理出的5 條高頻翻車(chē)記錄每條都按「現(xiàn)象 → 原因 → 解決」給出可立即執(zhí)行的方案。4.1 現(xiàn)象程序啟動(dòng)后立即卡死ps aux | grep bankcounter顯示進(jìn)程狀態(tài)為Duninterruptible sleep原因sem_wait(customer_sem)在main()創(chuàng)建柜員線程后立即執(zhí)行而此時(shí)customer_sem初始值為0且尚無(wú)顧客線程sem_post導(dǎo)致所有柜員線程永久阻塞。但更深層原因是——顧客線程創(chuàng)建順序晚于柜員線程且顧客sleep(arrive_time)延遲了sem_post。解決強(qiáng)制顧客線程先于柜員線程啟動(dòng)在main()中for循環(huán)創(chuàng)建顧客線程后加一句usleep(10000)10ms再創(chuàng)建柜員線程。這給了第一個(gè)顧客線程足夠時(shí)間執(zhí)行到sem_post(customer_sem)?；蚋鼉?yōu)解用 barrier 同步在main()初始化后聲明pthread_barrier_t start_barrier; pthread_barrier_init(start_barrier, NULL, COUNTER_NUM customer_list.size());所有線程啟動(dòng)后第一句都pthread_barrier_wait(start_barrier);確保所有線程“同時(shí)起跑”。4.2 現(xiàn)象輸出文件output.txt中多個(gè)顧客的service_start時(shí)間相同且早于其arrive_time原因time(NULL) - program_start_time計(jì)算的是絕對(duì)時(shí)間差但program_start_time是main()開(kāi)始時(shí)記錄的而顧客線程的sleep(customer.arrive_time)是相對(duì)main()啟動(dòng)后的偏移。當(dāng)多個(gè)顧客arrive_time相同如樣例中1 1 11、2 1 4、3 1 7它們幾乎同時(shí)sleep結(jié)束并sem_post柜員線程time(NULL)獲取的是同一秒內(nèi)的值導(dǎo)致service_start相同。解決不要用time()做高精度計(jì)時(shí)改為用clock_gettime(CLOCK_MONOTONIC, ts)獲取納秒級(jí)單調(diào)時(shí)鐘struct timespec ts; clock_gettime(CLOCK_MONOTONIC, ts); long long now_ms ts.tv_sec * 1000LL ts.tv_nsec / 1000000LL; // 然后用 now_ms - program_start_ms 計(jì)算毫秒級(jí)偏移4.3 現(xiàn)象segmentation fault (core dumped)gdb顯示崩潰在customer_waiting.front()或customer_waiting.pop()原因customer_waiting是空隊(duì)列時(shí)調(diào)用了front()/pop()。這通常發(fā)生在——柜員線程sem_wait(customer_sem)返回后認(rèn)為隊(duì)列非空但此時(shí)另一個(gè)柜員線程已搶先pop()導(dǎo)致本線程面對(duì)空隊(duì)列。根本原因是sem_wait只保證“有顧客”不保證“隊(duì)列非空”因?yàn)樾盘?hào)量和隊(duì)列操作不是原子的。解決必須在pthread_mutex_lock后、front()前再次檢查隊(duì)列是否為空pthread_mutex_lock(mutex); if (customer_waiting.empty()) { pthread_mutex_unlock(mutex); continue; // 重新 wait避免 crash } Customer customer *customer_waiting.front(); // ... rest of code4.4 現(xiàn)象編譯時(shí)報(bào)錯(cuò)undefined reference to sem_init或pthread_mutex_init原因鏈接器找不到libpthread和librt。雖然-lpthread參數(shù)寫(xiě)了但g 鏈接順序要求目標(biāo)文件必須在庫(kù)之前。如果寫(xiě)成g -lpthread bankcounter.cpp -o bankcounter鏈接器會(huì)忽略-lpthread。解決嚴(yán)格按g [源文件] -o [輸出] [選項(xiàng)]順序g -stdc11 bankcounter.cpp -o bankcounter -lpthread -lrt # 注意-lrt 必須加上因?yàn)?clock_gettime 在 librt 中4.5 現(xiàn)象output.txt輸出正常但終端cout日志中[CUSTOMER]和[COUNTER]交錯(cuò)混亂甚至同一行出現(xiàn)兩段輸出原因cout是緩沖流多線程同時(shí)寫(xiě)入時(shí)操作符不是原子的。例如cout A B可能被拆成write(A)和write(B)中間被其他線程插入。解決所有cout必須包裹在pthread_mutex_lock/unlock中項(xiàng)目代碼已做到但還需禁用緩沖// 在 main() 開(kāi)頭添加 std::ios::sync_with_stdio(false); cin.tie(nullptr); cout.tie(nullptr); // 并確保每次 cout 后 flush cout ... endl; // endl 自帶 flush // 或 cout ... flush;提示以上 5 條全是真實(shí)發(fā)生過(guò)的血淚經(jīng)驗(yàn)。如果你的程序跑不通優(yōu)先對(duì)照這 5 條排查80% 的問(wèn)題都能當(dāng)場(chǎng)解決。別急著重寫(xiě)邏輯先看是不是環(huán)境或編譯鏈的問(wèn)題。5. 二次開(kāi)發(fā)實(shí)戰(zhàn)從 FIFO 調(diào)度到優(yōu)先級(jí)叫號(hào)的三步改造這個(gè)項(xiàng)目最迷人的地方不是它實(shí)現(xiàn)了基礎(chǔ)功能而是它的架構(gòu)像樂(lè)高一樣可以輕松替換核心調(diào)度策略。比如原始版本用queueCustomer*實(shí)現(xiàn)先進(jìn)先出FIFO叫號(hào)但現(xiàn)實(shí)中銀行可能有 VIP 顧客插隊(duì)、老人優(yōu)先、或者按服務(wù)時(shí)長(zhǎng)排序短作業(yè)優(yōu)先。下面我就帶你用三步把 FIFO 改造成基于顧客服務(wù)時(shí)長(zhǎng)的優(yōu)先級(jí)隊(duì)列Shortest Job First, SJF全程不碰信號(hào)量和線程創(chuàng)建邏輯只改數(shù)據(jù)結(jié)構(gòu)和叫號(hào)算法。5.1 第一步替換 queue 為 priority_queue定義比較規(guī)則原始代碼用#include queue現(xiàn)在我們要換成#include queue#include functional并定義一個(gè)按service_duration升序排列的比較器// 替換原來(lái)的 std::queueCustomer* #include queue #include functional // 自定義比較器service_duration 小的優(yōu)先級(jí)高SJF struct CompareByDuration { bool operator()(const Customer* a, const Customer* b) const { return a-service_duration b-service_duration; // min-heap } }; std::priority_queueCustomer*, std::vectorCustomer*, CompareByDuration customer_waiting;為什么用而不是priority_queue默認(rèn)是大頂堆最大值在 top而我們需要最小服務(wù)時(shí)長(zhǎng)在 top所以比較器返回a-dur b-dur這樣a的 dur 更小a就會(huì)被“推”到頂部。這是 C STL 里容易混淆的點(diǎn)。5.2 第二步修改柜員線程的叫號(hào)邏輯適配 priority_queuepriority_queue沒(méi)有front()和pop()分離操作它的top()返回引用pop()移除頂部元素。所以柜員線程中相關(guān)代碼要微調(diào)// 原來(lái)的 queue 代碼 // Customer customer *customer_waiting.front(); // customer_waiting.pop(); // 改為 priority_queue 代碼 Customer customer *customer_waiting.top(); // 獲取服務(wù)時(shí)長(zhǎng)最短的顧客 customer_waiting.pop(); // 移除他注意priority_queue::top()返回的是const Customer*但因?yàn)槲覀兇娴氖侵羔?top()得到的是Customer可以安全修改service_start和counter_id。無(wú)需任何額外 cast。5.3 第三步驗(yàn)證與對(duì)比——用同一份 input.txt 測(cè)試 FIFO vs SJF準(zhǔn)備一份input_sjf.txt包含服務(wù)時(shí)長(zhǎng)差異大的顧客1 0 10 2 0 2 3 0 5 4 0 1分別編譯運(yùn)行 FIFO 版和 SJF 版對(duì)比output.txt顧客 IDFIFO 開(kāi)始時(shí)間SJF 開(kāi)始時(shí)間說(shuō)明100都是第一個(gè)到達(dá)FIFO 和 SJF 一致210等1服務(wù)完21服務(wù)中2最短插隊(duì)SJF 讓短作業(yè)先做減少平均等待時(shí)間31274173計(jì)算平均等待時(shí)間FIFO顧客2等待10s顧客3等待12s顧客4等待17s → 平均 ≈ 13sSJF顧客2等待2s顧客3等待7s顧客4等待3s → 平均 ≈ 4s提升 69%。這就是調(diào)度算法的價(jià)值——不用改并發(fā)模型只換一個(gè)數(shù)據(jù)結(jié)構(gòu)性能立竿見(jiàn)影。從那以后我每次做線程調(diào)度改造都強(qiáng)制走一遍“數(shù)據(jù)結(jié)構(gòu) → 算法接口 → 驗(yàn)證對(duì)比”三步。不迷信理論用input.txt和output.txt說(shuō)話。希望幫到你。本文還有配套的精品資源點(diǎn)擊獲取