闫文亮304 Kafka-生产者-BufferPool 先看注释 结合代码可知，BufferPool负责ByteBuffer的申请和释放。BufferPool会维持一组大小为...
发简信
IP属地：重庆
闫文亮304 Kafka-生产者-BufferPool 先看注释 结合代码可知，BufferPool负责ByteBuffer的申请和释放。BufferPool会维持一组大小为...
本文为原创文章，转载请注明出处 关注 pulsar 项目将近10天左右了，在此前，我和所有刚接触 pulsar 项目的人都有一个共同的疑惑，目前社区内已经有activeMQ、...
新增企业信息 接口地址:/Ent/EntEnterprise/create 请求方式:POST 请求数据类型:application/json 响应数据类型:*/* 接口描述...
一、官方文档解释 The database names of Activiti all start with ACT_. The second part is a two-c...
简述：目前通过源码得知camunda流程引擎，在系统启动时，会根据bpmn文件部署流程，所以我们来看下整个bpmn文件是如何加载存储并使用的。 源码入口SpringProce...
注：本文依赖于kafka-0.10.0.1-src 我们都知道kafka生产者send一条记录(record)后并没有直接发送到kafka服务端，而是先将它保存到内存...
其实在第一题，while循环里加个System.out.println(out)貌似也能正常退出。
多线程题分析今天工作的时候，同事提出了一道多线程的题目，题目虽然比较简单，但是还是能考察对多线程，JMM的理解程度的。 情况1 以下代码程序能不能正常结束？为什么 答案：不能执行结束，原...
一、前言 CountDownLatch是一个同步辅助器，用于一个线程等待多个线程执行完操作后再执行。 二、主要特点 拥有一个初使值，定义等待并发线程执行的数目 await方法...
一、前言 之前在AQS中介绍到其中的Condition队列，而今天本文就介绍与其相关的Condition。Condition是一个多线程间协调通信的工具类，在synchorn...
@小川先森 我的理解是我们使用锁的场景时，对于去state的操作是一个读多写少的过程，所以我认为适合这种自旋的cas操作
java并发包之AQS一、前言 AQS的全称为（AbstractQueuedSynchronizer），我们知道的java.util.concurrent包下很多类如，ReetrantLock ，...
一、前言 在上文中谈到了AQS是Lock实现的前提，而本文说到的ReetrantLock就是在此基础上处理的。而本文中会对ReetrantLock公平性，可重入性等进行介绍。...
一、前言 AQS的全称为（AbstractQueuedSynchronizer），我们知道的java.util.concurrent包下很多类如，ReetrantLock ，...
