在SPI SRAM上使用生產者和消費者模型初步分析

2021-08-25 19:25:40 字數 724 閱讀 3167

下面是**的原型, 這裡用了陣列buffer作為截體, 如何截體換成乙個結構,用來對spi sram進行抽象, 就可以在spi sram晶元上使用生產者和消費者模型(它們的中介/中間層是乙個ring buf環形緩衝區).

#include #include #include const int datasize = 100000;//<>

const int buffersize = 4096;//<>

static char buffer[buffersize];/*char陣列對緩衝的抽象,也可以換成乙個結構,用來對spi sram進行抽象,

就可以在spi sram晶元上使用生產者和消費者模型(它們的中介/中間層是乙個ring buf環形緩衝區)*/

//用兩個訊號量來同步生產者和消費者執行緒

static qsemaphore freespace(buffersize);//可寫空間

static qsemaphore usedspace(0); //可讀空間

class producer : public qthread

;void producer::run()

}class consumer : public qthread

;void consumer::run()

//std::cerr << std::endl;

}int main()

使用joinablequeue的生產者和消費者模型

import multiprocessing import queue import time def consumer output q print time is format time.ctime while true item output q.get print pull item out...

kafka同步生產者和非同步生產者深入剖析

什麼是kafka同步生產者,什麼是kafka非同步生產者?比如這裡某個topic有3個分割槽。kafka同步生產者 這個生產者寫一條訊息的時候,它就立馬傳送到某個分割槽去。kafka非同步生產者 這個生產者寫一條訊息的時候,先是寫到某個緩衝區,這個緩衝區裡的資料還沒寫到broker集群裡的某個分割槽...

生產者和消費者

package demo.one public class producerconsumerdemo 資源 class resource catch interruptedexception e this.name name count system.out.println thread.curre...