消息发送流程 1.生产者main线程调用send发送消息，先走拦截器，然后会将消息进行序列化，然后选择对应的分区器，将消息发送到RecordAccumulator中，默认是32m 2.Sender线程会异步读取，要不数据达到batch的大小 进行数据拉取，要么数据达到linger的时间，读取数据之后通过网络进行将数据发送到Kafka集群。如果出现失败在进行重试，直到B 继续阅读

目录 一.什么是阻塞队列(BlockingDeque) 二.阻塞队列有什么用? 三.运用阻塞队列来实现一个最简单的生产者消费者 四.模拟实现阻塞队列 一.什么是阻塞队列(BlockingDeque) 既然叫做阻塞队列,那么他就满足两个特性 1.队列:先进先出 2.阻塞:空了不让出,满了不让进 （1）如果队列为空，尝试出队列，就会出现阻塞，阻塞到队列不为空为止；（2&#x 继续阅读

蚂蚁实习一面复盘总结4.13 算法题 1、设计一个算法，求第k个最大的数； 直接排序求第k个使用选择排序、冒泡排序、插入排序等排到第k个就返回更快的方法：快排的分治法、最小堆最大堆法，当场写出来还是很难的 2、写单例模式 面试部分 1、RabbitMQ如何保证消息可靠性？ 生产者、消费者、消息队列本身 2、RabbitMQ如何保证消息有序性？ 出现乱序的情况：一个队列多个消费者、一 继续阅读

为了更有效地同步对任何资源的访问，我们可以将条件与任务相关联，让任何线程等待，直到满足某个条件，或者通知其他线程该条件正在满足，以便它们可以解除对自身的阻止。 让我们举一个简单的例子来理解这一点。在生产者消费者问题中，如果有一个生产者生产某一物品，一个消费者消费该物品，那么在生产者生产该物品之前，消费者不能消费该物品。因此，消费者要等到产品生产出来。生产者有责任告知消费者，一旦产品成功生产，就可以消费。 如果有多个消费者消费生产者生产的产品，那么生产者必须通知所 继续阅读