《对线面试官》系列目前已经连载31篇啦,这是一个讲人话面试系列 【对线面试官】Java注解 【对线面试官】Java泛型 【对线面试官】 Java NIO 【对线面试官】Java反射 && 动态代理 【对线面试官】多线程基础 【对线面试官】 CAS 【对线面试官】synchronized 【对线面试官 ...
分类:
其他好文 时间:
2021-07-27 17:37:43
阅读次数:
0
FutureTask(未来任务) 一、前情回顾(重要) 首先我们先回顾一下多线程创建的方式 直接继承Thread方式 实现Runnable 方式 实现Callable方式 线程池方式 这四种方式主要分为两类:没返回值的(1,2) 有返回值的(3,4) 没返回值的相信已经烂熟于心了。这次我们讲讲有返回 ...
分类:
其他好文 时间:
2021-07-26 16:46:03
阅读次数:
0
1、轮询策略:按照消息尽量保证每个分区的负载,消息会均匀分布到每个partition。写入消息的时候,key为null的时候,默认使用的是轮询策略。 2、随机策略:不使用。 3、按key写入策略:key.hash()%分区的数量。 4、自定义分区策略:类似于mapReduce指定分区。 乱序问题: ...
分类:
其他好文 时间:
2021-07-26 16:34:25
阅读次数:
0
[TOP] pytest 常用插件(pip install 安装) pytest-html : 用于生成html格式的自动化测试报告 pytest-xdist: 用于多线程执行用例的插件 pytest-ordering:用于改变测试用例执行顺序 pytest-rerunfailures:失败的用例重 ...
分类:
其他好文 时间:
2021-07-22 17:34:46
阅读次数:
0
一、broker消息存储 本节揭露broker上消息存储的真实目录结构+存储方式。 1.1 目录、文件结构 有3个比较重要的文件: commitLog消息日志:消息主体以及元数据的存储主体,存储Producer端写入的消息主体内容, consumequeue逻辑消费队列:存储了commitLog的起 ...
分类:
其他好文 时间:
2021-07-21 17:31:03
阅读次数:
0
线程池的作用 在多线程的应用中,线程的频繁创建和销毁会浪费时间,从而影响效率,所以引进线程池和概念,将多个线程维护在线程池中,避免了线程频繁创建与销毁的开销问题 线程池的结构 结构体 struct threadpool_t { pthread_mutex_t lock; //互斥锁 pthread_ ...
分类:
编程语言 时间:
2021-07-19 16:30:19
阅读次数:
0
Python支持多线程,但是由于GIL的限制并不能无限制的开启子线程。 通过semaphore我们可以控制子线程对于共享资源的访问,即可以阻塞一些子线程直到有空余的semaphore资源,但是并不能实际限制子线程数。 当我们需要开启成千上万个子线程时,很多时候并不希望这些子线程同时执行(可能受限于系 ...
分类:
编程语言 时间:
2021-07-15 19:01:30
阅读次数:
0
数据积压指的是消费者因为一些外部的IO、一些比较耗时的操作(full GC--stop the world),就会造成消息在partition中一直存在得不到消费,就会产生数据积压。 所以需要监控系统(kafka的监控系统Eagle),如果出现这种情况,需要尽快处理,虽然后续的spark strea ...
分类:
其他好文 时间:
2021-07-13 17:40:18
阅读次数:
0
RabbitMQ知识详解 一、什么是消息队列 消息队列,即MQ,Message Queue。消息队列是典型的:生产者、消费者模型。生产者不断向消息队列中生产消息,消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的,而且只关心消息的发送和接收,没有业务逻辑的侵入,这样就实现了生产者和消费者的 ...
分类:
其他好文 时间:
2021-07-05 18:52:35
阅读次数:
0
最近有项目需要去某个文件夹里面,获取所有XML文件,然后从XML文件中查找特定节点中查找是否有特定信息。 为了便于获取所有文件信息,直接用bat文件每天自动运行生成一个文件列表list信息供查看。 cd /d %~dp0 dir /s /b *.* > FileList.txt 所以接下来要做的事情 ...
分类:
编程语言 时间:
2021-07-05 16:50:22
阅读次数:
0