多线程不重复读取数据_别再犯错了,多线程访问同一个资源一定要上锁?
生活随笔
收集整理的這篇文章主要介紹了
多线程不重复读取数据_别再犯错了,多线程访问同一个资源一定要上锁?
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
大家都知道,多線程訪問同一個資源必須要做同步互斥,一定要用到鎖,這個說法是完全正確的嗎?
以常見的生產者消費者模型舉例,這里我們只有一個生產者,一個消費者。即,一個線程不斷的從一個設備讀取數據,放入緩沖區buff0,這個是生產者。另一個線程不斷從緩沖區buff0取出數據,這個是消費者。
針對上面這種場景,我們設計如下數據結構(環形緩沖區):
#define MAX_LEN 1024struct ring_buf{ char data[MAX_LEN]; int w_pos; int r_pos;};我們的程序偽代碼如下:
生產者:while(1){ int read_length=read(tmpBuf); if(根據w_pos和r_pos的值判斷緩沖區剩余空間足夠){ copy2ringBuf(ring_buf[w_pos],tmpBuf,read_length); 根據read_length調整w_pos的值; }else 等待消費者線程消耗數據;};消費者:while(1){ int want_length=100; if(根據w_pos和r_pos的值判斷緩沖區數據大于100){ readFromRingBuf(tmpBuf,ring_buf[w_pos],want_length); 根據want_length調整r_pos的值; }else 等待生產者創造數據;};我們看到雖然倆個線程都會訪問同一個緩沖區,但是我們并沒有使用鎖來做互斥,而是使用了倆個變量w_pos及r_pos來做互斥。生產者只會修改w_pos的值,消費者只會修改r_pos的值。完全不需要鎖
環形緩沖區示意圖
創作挑戰賽新人創作獎勵來咯,堅持創作打卡瓜分現金大獎總結
以上是生活随笔為你收集整理的多线程不重复读取数据_别再犯错了,多线程访问同一个资源一定要上锁?的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 汞是一种什么的金属
- 下一篇: 中年男网名微信网名102个