下载相关的 api 可以到中泰官网。

接收行情的回调函数需要以最快速度返回。

	///行情通知
	///@param market_data 行情数据，需要快速返回，否则会堵塞后续消息，当堵塞严重时，会触发断线
	virtual void OnMarketData(XTPMD *market_data) {}

经查看指针地址可知， market_data 分配在栈上。因此不能直接在这里进行异步操作，因为不保证这个地址此后还能有效。
所以避免不开两个问题，一个是内存拷贝，一个是写文件。
为达到最快的存储速度，采用以下两个优化：

1. 使用 Ringbuffer 存储
   避免每次接收到行情时进行内存分配。 参考内核的 kfifo 编写。
2. 异步写文件
   io 操作是最费时的。必须异步进行。

1. 线程池
   之前每次写文件，都需要创建一个线程，执行完毕后销毁。创建线程是一个较大的开销。
   于是使用一个线程池改进。目前只需要在线程池中开启一个线程即可。