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);			
		}
	}

 

相關文章
相關標籤/搜索