我们在开发过程中经常会遇到需要从一个地方不断获取数据然后又需要交给另一个线程对数据进行二次加工的情况，这种场景适合使用生产者-消费者模式。
2021-12-09 12:04:52
165KB
1
const unsigned short SIZE_OF_BUFFER = 20;//有界缓冲区长度
int g_buffer[SIZE_OF_BUFFER];//开辟缓冲区，用数组表示，可以看成是一个循环队列
unsigned short ProductID = 0;//新生产出来的产品的产品号
unsigned short ConsumeID = 0;//被消耗的产品的产品号
unsigned short in = 0;//产品进缓冲区时的缓冲区下标，用于记录生产者的指针位置
unsigned short out = 0;//产品出缓冲区时的缓冲区下标，用于记录消费者的指针位置
bool g_continue = 1;//控制程序运行：1表示继续运行，0表示停止运行
2021-06-09 18:43:00
6KB
1
主要介绍了Java实现Kafka生产者消费者代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2021-04-08 15:22:12
85KB
1