生產者消費者模式

2021-08-07 14:27:13 字數 1520 閱讀 1495

常見場景:

某個模組負責產生資料,這些資料由另乙個模組來負責處理。產生資料的模組,就形象地稱為生產者;而處理資料的模組,就稱為消費者。

該模式還需要有乙個緩衝區處於生產者和消費者之間,作為乙個中介。生產者把資料放入緩衝區,而消費者從緩衝區取出資料

緩衝區作用

1. 解耦,生產者和消費者只依賴緩衝區,而不互相依賴

2. 支援併發和非同步

方式一,同步佇列

/**

* 生產者、消費者緩衝區 */

public

class storage implements

istorage

catch

(interruptedexception e)

}queue.add(obj);

system.out.println("進入緩衝區");

queue.notifyall();}}

@override

public

object get()

catch

(interruptedexception e)

}obj =queue.poll();

system.out.println("離開緩衝區");

queue.notifyall();

}return

obj;}}

方式二,可重入鎖

public

class storage implements

istorage

catch

(interruptedexception e)

}list.add(obj);

system.out.println("進入緩衝區");

empty.signalall();

lock.unlock();

}@override

public

object get()

catch

(interruptedexception e)

}object obj =list.remove();

system.out.println("離開緩衝區");

full.signalall();

lock.unlock();

return

obj;}}

方式三,阻塞佇列

public

class storage implements

istorage

catch

(interruptedexception e)

system.out.println("進入緩衝區");

}@override

public

object get()

catch

(interruptedexception e)

system.out.println("離開緩衝區");

return

obj;}}

生產者消費者 生產者與消費者模式

一 什麼是生產者與消費者模式 其實生產者與消費者模式就是乙個多執行緒併發協作的模式,在這個模式中呢,一部分執行緒被用於去生產資料,另一部分執行緒去處理資料,於是便有了形象的生產者與消費者了。而為了更好的優化生產者與消費者的關係,便設立乙個緩衝區,也就相當於乙個資料倉儲,當生產者生產資料時鎖住倉庫,不...

生產者 消費者模式

一 我哥們把資料存入redis快取區 生產者 二 我從緩衝器取資料,並作處理!消費者 詳細 如下 取訂單並判斷 redis new redis conn flag redis connect redis translate usefull host,redis translate usefull p...

生產者 消費者模式

是為了更好處理併發程式設計中程序同步問題。解決生產速率和消費速率不匹配的問題,如果不使用生產者消費者模式,生產速度過快,而消費者處理速度過慢,則必須等待消費者處理完才能繼續生產 同樣如果消費者處理速度大於生產者處理速度,那麼消費者必須等待生產者生產了才能繼續處理。而生產者 消費者模式通過引入乙個生產...