線程同步相關(guān)問題

kdkgod

場(chǎng)景是這樣的,
thread()
{
  while (1) {
   while (readdata() == success) {
      //正常業(yè)務(wù)邏輯
   }
    //現(xiàn)在沒有數(shù)據(jù)處理時(shí)直接sleep 1 ms,如果sleep時(shí)間過長(zhǎng),會(huì)可能導(dǎo)致數(shù)據(jù)積壓,如果sleep時(shí)間過短,就會(huì)cpu占用過高,
   除了信號(hào)量 有沒有其他的辦法,
  }
}

-----------------------------------------
今天將sleep 1ms改成用信號(hào)量,發(fā)現(xiàn)cpu占用比之前高了. 說明一下,每秒收到的包還是挺多的,1s應(yīng)該有近1w條.

coolmoon_133319

個(gè)人認(rèn)為讀數(shù)據(jù)接口應(yīng)該交給內(nèi)核去處理。具體地講，就是有數(shù)據(jù)時(shí)，內(nèi)核會(huì)通知應(yīng)用程序（比如epoll）去處理事情，沒有數(shù)據(jù)時(shí)就阻塞，系統(tǒng)資源被操作系統(tǒng)回收，處理其它事情。關(guān)鍵在于設(shè)置為阻塞式。

kdkgod

.................

從哪看出來是socket啦
回復(fù) 2# coolmoon_133319


   

coolmoon_133319

猜的哈，一般網(wǎng)絡(luò)程序這樣子寫的多。

非socket也沒關(guān)系嘛，可以設(shè)置為阻塞式。

lxyscls

pthread_cond_t

lxyscls

回復(fù) 3# kdkgod


    其實(shí)也可以用socket，producer把data enqueue，然后通知consumer，consumer在socket接收函數(shù)里面dequeue

yulihua49

lxyscls 發(fā)表于 2015-11-13 17:02
pthread_cond_t

正解！

//消費(fèi)者
pthread_mutex_lock（&mux）
while（NULL==(ptr=get_data())){
        pthread_cond_wait(&cond,&mux);
}
pthread_mutex_unlock（&mux）

// 生產(chǎn)者
pthread_mutex_lock（&mux）
put_data()；
pthread_mutex_unlock（&mux）
pthread_cond_signal(&cond);

這個(gè)模型可以多對(duì)多。

drangon

其實(shí)大部分情況下，CPU占用都不會(huì)高的，sleep 1ms或者10ms很好用的，cpu多耗5%根本不是事，

yulihua49

drangon 發(fā)表于 2015-11-14 13:15
其實(shí)大部分情況下，CPU占用都不會(huì)高的，sleep 1ms或者10ms很好用的，cpu多耗5%根本不是事，

響應(yīng)速度1ms就意味著每秒只能1000個(gè)事物，你能容忍就行。

qw10371006

這個(gè)明顯采用線程的掛起與**啊。不需要操作的時(shí)候就使用pthread_cond_t與鎖配合將線程掛起，等有需要的時(shí)候就發(fā)送一個(gè)信號(hào)給此掛起的線程繼續(xù)執(zhí)行。