Disruptor底层源码解析(九)

 架构图:java

性能为何这么牛逼:架构

 

 

 

 

 

 

public void sendData(ByteBuffer data) {
		//1 在生产者发送消息的时候, 首先 须要从咱们的ringBuffer里面 获取一个可用的序号
		long sequence = ringBuffer.next();	//0	
		try {
			//2 根据这个序号, 找到具体的 "OrderEvent" 元素 注意:此时获取的OrderEvent对象是一个没有被赋值的"空对象"
			OrderEvent event = ringBuffer.get(sequence);
			//3 进行实际的赋值处理
			event.setValue(data.getLong(0));			
		} finally {
			//4 提交发布操做
			ringBuffer.publish(sequence);			
		}
	}

 

相关文章
相关标签/搜索