生产者消费者模型
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了生产者消费者模型相关的知识，希望对你有一定的参考价值。
参考技术A 生产者消费者模型，是为了对象被线程同步访问；银行家算法，或者说是模型，加锁是为了共享对象的安全访问，也即互斥访问，保证共享对象的线程安全。线程同步，按顺序执行，是要做线程间的同步通信的。而生产者消费者模型需要的互斥信号量是2个，FULL信号量和EMPTY信号量。所以说多线程的时候，共享对象需要安全访问的时候，要加锁，实现互斥访问就行，也引申出来锁。锁与flag不要混淆。一定要注意共享，不然的话就没意思了，也正如在多线程里说的那样，线程完全可以有ThreadLocal对象，这样各线程间相安无事。同步机制也是要了解一下的。
KafkaKafka生产者和消费者模型
消费者模型
消费模型有分区消费模型、组消费模型。
分区消费模型：
可以看到在这种模型下分区和消费者是对应的，为了保证最大效率通常一个分区对应一个消费者。
生产者模型
以上是关于生产者消费者模型的主要内容，如果未能解决你的问题，请参考以下文章